From d3c9fef7b472e751e459c6a0104bb3a8a4bda7ad Mon Sep 17 00:00:00 2001 From: Sergey Cherepanov Date: Mon, 17 Apr 2023 17:00:35 +0200 Subject: [PATCH] update conf on start --- nodeconf/service.go | 21 ++++++++++++++------- 1 file changed, 14 insertions(+), 7 deletions(-) diff --git a/nodeconf/service.go b/nodeconf/service.go index 199a82aa..5fa40db2 100644 --- a/nodeconf/service.go +++ b/nodeconf/service.go @@ -66,19 +66,26 @@ func (s *service) Run(_ context.Context) (err error) { func (s *service) updateLoop(ctx context.Context) { ticker := time.NewTicker(time.Minute * 10) defer ticker.Stop() + + updateConf := func() { + err := s.updateConfiguration(ctx) + if err != nil { + if err == ErrConfigurationNotChanged { + return + } + log.Info("can't update configuration", zap.Error(err)) + } + } + + updateConf() + for { select { case <-s.updateCtx.Done(): return case <-ticker.C: } - err := s.updateConfiguration(ctx) - if err != nil { - if err == ErrConfigurationNotChanged { - continue - } - log.Info("can't update configuration", zap.Error(err)) - } + updateConf() } }