diff --git a/proxyd/proxyd/server.go b/proxyd/proxyd/server.go index 2564ef6..b52224c 100644 --- a/proxyd/proxyd/server.go +++ b/proxyd/proxyd/server.go @@ -222,6 +222,11 @@ func (s *Server) Shutdown() { if s.wsServer != nil { _ = s.wsServer.Shutdown(context.Background()) } + for _, bg := range s.BackendGroups { + if bg.Consensus != nil { + bg.Consensus.Shutdown() + } + } } func (s *Server) HandleHealthz(w http.ResponseWriter, r *http.Request) {