diff --git a/pkg/cloudcommon/app/endpoint.go b/pkg/cloudcommon/app/endpoint.go index 040e4881f5..8cd65f2519 100644 --- a/pkg/cloudcommon/app/endpoint.go +++ b/pkg/cloudcommon/app/endpoint.go @@ -30,6 +30,7 @@ type SEndpointChangeManager struct { func newEndpointChangeManager() *SEndpointChangeManager { man := &SEndpointChangeManager{} man.InitSync(man) + man.FirstSync() return man } diff --git a/pkg/keystone/models/endpoints.go b/pkg/keystone/models/endpoints.go index 1911cc3436..0bb12f12de 100644 --- a/pkg/keystone/models/endpoints.go +++ b/pkg/keystone/models/endpoints.go @@ -631,3 +631,13 @@ func (endpoint *SEndpoint) ValidateUpdateData( } return data, nil } + +func TrySetInformerBackend() { + endpoint, err := EndpointManager.FetchByName(nil, apis.SERVICE_TYPE_ETCD) + if err != nil { + log.Errorf("Failed fetch etcd service endpoint: %s", err) + return + } + ep := endpoint.(*SEndpoint) + ep.trySetInformerBackend() +} diff --git a/pkg/keystone/service/service.go b/pkg/keystone/service/service.go index 59c3c77b33..9788336cd0 100644 --- a/pkg/keystone/service/service.go +++ b/pkg/keystone/service/service.go @@ -70,6 +70,7 @@ func StartService() { InitHandlers(app) db.EnsureAppInitSyncDB(app, &opts.DBOptions, models.InitDB) + models.TrySetInformerBackend() app_common.InitBaseAuth(&opts.BaseOptions)