diff options
Diffstat (limited to 'msb2pilot/src/msb2pilot/pilot/controller.go')
| -rw-r--r-- | msb2pilot/src/msb2pilot/pilot/controller.go | 17 |
1 files changed, 12 insertions, 5 deletions
diff --git a/msb2pilot/src/msb2pilot/pilot/controller.go b/msb2pilot/src/msb2pilot/pilot/controller.go index f0cf87d..4070ad3 100644 --- a/msb2pilot/src/msb2pilot/pilot/controller.go +++ b/msb2pilot/src/msb2pilot/pilot/controller.go @@ -41,7 +41,7 @@ const ( [{}, {}] is error. {} {} is right */ func ParseParam(input string) ([]model.Config, error) { - configs, _, err := crd.ParseInputs(input) + configs, _, err := crd.ParseInputsWithoutValidation(input) return configs, err } @@ -63,15 +63,22 @@ func Save(operation Operation, configs []model.Config) []*model.Config { } func init() { - updateK8sAddress(configPath) + var k8sConfigPath string + k8sAddr, _ := updateK8sAddress(configPath) + if k8sAddr != "" { + k8sConfigPath = configPath + } var err error - client, err = crd.NewClient(configPath, model.ConfigDescriptor{ - model.RouteRule, - model.DestinationPolicy, + client, err = crd.NewClient(k8sConfigPath, "", model.ConfigDescriptor{ + model.VirtualService, model.DestinationRule, }, "") + if err = client.RegisterResources(); err != nil { + log.Log.Error("failed to register custom resources.", err) + } + if err != nil { log.Log.Error("fail to init crd", err) } |