From e2411b63ea83374c916a067bb7d59264e482222b Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E5=B1=88=E8=BD=A9?= Date: Tue, 14 Jun 2022 00:46:34 +0800 Subject: [PATCH] fix(cloudevent): allow disable sync cloudevent (#14446) --- pkg/cloudevent/models/cloudproviders.go | 3 +++ pkg/cloudevent/options/options.go | 2 ++ 2 files changed, 5 insertions(+) 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"` }