diff options
Diffstat (limited to 'workhorse/main.go')
| -rw-r--r-- | workhorse/main.go | 7 |
1 files changed, 4 insertions, 3 deletions
diff --git a/workhorse/main.go b/workhorse/main.go index 91008e16961..b0f9760b0d5 100644 --- a/workhorse/main.go +++ b/workhorse/main.go @@ -220,9 +220,10 @@ func run(boot bootConfig, cfg config.Config) error { secret.SetPath(boot.secretPath) + keyWatcher := redis.NewKeyWatcher() if cfg.Redis != nil { redis.Configure(cfg.Redis, redis.DefaultDialFunc) - go redis.Process() + go keyWatcher.Process() } if err := cfg.RegisterGoCloudURLOpeners(); err != nil { @@ -237,7 +238,7 @@ func run(boot bootConfig, cfg config.Config) error { gitaly.InitializeSidechannelRegistry(accessLogger) - up := wrapRaven(upstream.NewUpstream(cfg, accessLogger)) + up := wrapRaven(upstream.NewUpstream(cfg, accessLogger, keyWatcher.WatchKey)) done := make(chan os.Signal, 1) signal.Notify(done, syscall.SIGINT, syscall.SIGTERM) @@ -271,7 +272,7 @@ func run(boot bootConfig, cfg config.Config) error { ctx, cancel := context.WithTimeout(context.Background(), cfg.ShutdownTimeout.Duration) // lint:allow context.Background defer cancel() - redis.Shutdown() + keyWatcher.Shutdown() return srv.Shutdown(ctx) } } |