diff --git a/api/handler/handler.go b/api/handler/handler.go index 312df8cf3..cce3b4e11 100644 --- a/api/handler/handler.go +++ b/api/handler/handler.go @@ -70,7 +70,7 @@ func InitHandle(conf option.Config, statusCli *client.AppRuntimeSyncClient) erro return err } defaultGatewayHandler = CreateGatewayManager(dbmanager, mqClient) - def3rdPartySvcHandler = Create3rdPartySvcHandler(dbmanager) + def3rdPartySvcHandler = Create3rdPartySvcHandler(dbmanager, statusCli) operationHandler = CreateOperationHandler(mqClient) batchOperationHandler = CreateBatchOperationHandler(mqClient, operationHandler) diff --git a/gateway/store/store.go b/gateway/store/store.go index fa0484f20..be93970af 100644 --- a/gateway/store/store.go +++ b/gateway/store/store.go @@ -34,8 +34,7 @@ import ( "github.com/eapache/channels" "github.com/goodrain/rainbond/cmd/gateway/option" "github.com/goodrain/rainbond/gateway/annotations" - v1 "github.com/goodrain/rainbond/gateway/v1" - apiv1 "k8s.io/api/core/v1" + "github.com/goodrain/rainbond/gateway/v1" corev1 "k8s.io/api/core/v1" extensions "k8s.io/api/extensions/v1beta1" metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" diff --git a/worker/handle/manager.go b/worker/handle/manager.go index d2544048a..c7136cd16 100644 --- a/worker/handle/manager.go +++ b/worker/handle/manager.go @@ -360,10 +360,10 @@ func (m *Manager) applyRuleExec(task *model.Task) error { } var newAppService *v1.AppService if svc.Kind == dbmodel.ServiceKindThirdParty.String() { - newAppService, err = conversion.InitAppService(m.dbmanager, body.ServiceID, + newAppService, err = conversion.InitAppService(m.dbmanager, body.ServiceID, nil, "ServiceSource", "TenantServiceBase", "TenantServiceRegist") } else { - newAppService, err = conversion.InitAppService(m.dbmanager, body.ServiceID) + newAppService, err = conversion.InitAppService(m.dbmanager, body.ServiceID, nil) } if err != nil { logrus.Errorf("Application init create failure:%s", err.Error())