Skip to content

Commit bd557b4

Browse files
committed
fix: remove duplicate sync func (#2476)
Signed-off-by: ashing <[email protected]>
1 parent f5b4f5b commit bd557b4

File tree

1 file changed

+0
-31
lines changed

1 file changed

+0
-31
lines changed

internal/manager/run.go

Lines changed: 0 additions & 31 deletions
Original file line numberDiff line numberDiff line change
@@ -21,7 +21,6 @@ import (
2121
"context"
2222
"crypto/tls"
2323
"os"
24-
"time"
2524

2625
"github.com/go-logr/logr"
2726
"k8s.io/apimachinery/pkg/runtime"
@@ -172,36 +171,6 @@ func Run(ctx context.Context, logger logr.Logger) error {
172171
return err
173172
}
174173

175-
go func() {
176-
setupLog.Info("starting provider sync")
177-
initalSyncDelay := config.ControllerConfig.ProviderConfig.InitSyncDelay.Duration
178-
time.AfterFunc(initalSyncDelay, func() {
179-
setupLog.Info("trying to initialize provider")
180-
if err := provider.Sync(ctx); err != nil {
181-
setupLog.Error(err, "unable to sync resources to provider")
182-
return
183-
}
184-
})
185-
186-
syncPeriod := config.ControllerConfig.ProviderConfig.SyncPeriod.Duration
187-
if syncPeriod < 1 {
188-
return
189-
}
190-
ticker := time.NewTicker(syncPeriod)
191-
defer ticker.Stop()
192-
for {
193-
select {
194-
case <-ticker.C:
195-
if err := provider.Sync(ctx); err != nil {
196-
setupLog.Error(err, "unable to sync resources to provider")
197-
return
198-
}
199-
case <-ctx.Done():
200-
return
201-
}
202-
}
203-
}()
204-
205174
setupLog.Info("check ReferenceGrants is enabled")
206175
_, err = mgr.GetRESTMapper().KindsFor(schema.GroupVersionResource{
207176
Group: v1beta1.GroupVersion.Group,

0 commit comments

Comments
 (0)