Added migrations
This commit is contained in:
@@ -68,10 +68,7 @@ func NewServer(conf *Config, logger *fluentd.Logger, db *pgxpool.Pool /*, ebCh *
|
||||
interval := time.Second * 30
|
||||
ticker := time.NewTicker(interval)
|
||||
for range ticker.C {
|
||||
err := s.updateKVConfig()
|
||||
if err != nil {
|
||||
logger.Log("KV config update error (skipping): %v\n", err)
|
||||
}
|
||||
s.updateKVConfig()
|
||||
}
|
||||
}(s)
|
||||
|
||||
|
||||
Reference in New Issue
Block a user