diff --git a/pkg/cloudevent/models/cloudproviders.go b/pkg/cloudevent/models/cloudproviders.go index 582d4e9088..f6a7127dbc 100644 --- a/pkg/cloudevent/models/cloudproviders.go +++ b/pkg/cloudevent/models/cloudproviders.go @@ -256,6 +256,9 @@ func (manager *SCloudproviderManager) syncCloudeventTask(ctx context.Context, us } func (manager *SCloudproviderManager) SyncCloudeventTask(ctx context.Context, userCred mcclient.TokenCredential, isStart bool) { + if options.Options.DisableSyncCloudEvent { + return + } err := manager.syncCloudeventTask(ctx, userCred) if err != nil { log.Errorf("syncCloudeventTask error: %v", err) diff --git a/pkg/cloudevent/options/options.go b/pkg/cloudevent/options/options.go index f19bbad356..32574cb1b8 100644 --- a/pkg/cloudevent/options/options.go +++ b/pkg/cloudevent/options/options.go @@ -23,6 +23,8 @@ type CloudeventOptions struct { CloudproviderSyncIntervalMinutes int `help:"frequency to sync region cloudprovider task" default:"15"` CloudeventSyncIntervalHours int `help:"frequency to sync cloud event task" default:"1"` + DisableSyncCloudEvent bool `help:"disable sync cloudevent" default:"false"` + SyncWithReadEvent bool `help:"sync read operation events" default:"false"` OneSyncForHours int `help:"Onece sync for hours" default:"1"` }