Skip to content

Commit

Permalink
feat(realtime): disable remote unused remote reloadable check
Browse files Browse the repository at this point in the history
  • Loading branch information
phanyzewski committed Apr 13, 2024
1 parent dd6c551 commit 2405621
Showing 1 changed file with 26 additions and 26 deletions.
52 changes: 26 additions & 26 deletions run.go
Original file line number Diff line number Diff line change
Expand Up @@ -96,32 +96,32 @@ func run(ctx context.Context, shutdown chan os.Signal) error {

// remote configuration reload
wg := sync.WaitGroup{}
wg.Add(1)
go func() {
defer wg.Done()
for {
ticker := time.NewTicker(time.Duration(1 * time.Hour))
defer ticker.Stop()
for {
if imup.cfg.Realtime() {
// when api sends a new config, reload it
if err := imup.remoteConfigReload(cctx); err != nil {
log.Error("failed to reload config", "error", err)
imup.Errors.write("RemoteConfigReload", err)
} else {
imup.Errors.reportErrors("RemoteConfigReload")
}
}

select {
case <-ticker.C:
continue
case <-cctx.Done():
return
}
}
}
}()
// wg.Add(1)
// go func() {
// defer wg.Done()
// for {
// ticker := time.NewTicker(time.Duration(1 * time.Hour))
// defer ticker.Stop()
// for {
// if imup.cfg.Realtime() {
// // when api sends a new config, reload it
// if err := imup.remoteConfigReload(cctx); err != nil {
// log.Error("failed to reload config", "error", err)
// imup.Errors.write("RemoteConfigReload", err)
// } else {
// imup.Errors.reportErrors("RemoteConfigReload")
// }
// }

// select {
// case <-ticker.C:
// continue
// case <-cctx.Done():
// return
// }
// }
// }
// }()

// liveness checkin
wg.Add(1)
Expand Down

0 comments on commit 2405621

Please sign in to comment.