From 6c586bc2a7a49755b4b2566c034bc1affc92011d Mon Sep 17 00:00:00 2001 From: Florian Klink Date: Mon, 18 Sep 2023 16:51:39 +0300 Subject: feat(tvix/nar-bridge): graceful shutdown This gives existing clients 30s to finish their requests after receiving an interrupt. Change-Id: Ia9b0e662fd1ffbbb6c2d03f3dd6548b13cf3d241 Reviewed-on: https://cl.tvl.fyi/c/depot/+/9365 Autosubmit: flokli Tested-by: BuildkiteCI Reviewed-by: Connor Brewster --- tvix/nar-bridge/pkg/server/server.go | 12 ++++++++++-- 1 file changed, 10 insertions(+), 2 deletions(-) (limited to 'tvix/nar-bridge/pkg/server/server.go') diff --git a/tvix/nar-bridge/pkg/server/server.go b/tvix/nar-bridge/pkg/server/server.go index 0de38c84dfee..f58842bfa792 100644 --- a/tvix/nar-bridge/pkg/server/server.go +++ b/tvix/nar-bridge/pkg/server/server.go @@ -1,6 +1,7 @@ package server import ( + "context" "fmt" "net/http" "sync" @@ -13,6 +14,7 @@ import ( ) type Server struct { + srv *http.Server handler chi.Router directoryServiceClient storev1pb.DirectoryServiceClient @@ -73,8 +75,14 @@ func New( return s } +func (s *Server) Shutdown(ctx context.Context) error { + return s.srv.Shutdown(ctx) +} + +// ListenAndServer starts the webserver, and waits for it being closed or +// shutdown, after which it'll return ErrServerClosed. func (s *Server) ListenAndServe(addr string) error { - srv := &http.Server{ + s.srv = &http.Server{ Addr: addr, Handler: s.handler, ReadTimeout: 500 * time.Second, @@ -82,5 +90,5 @@ func (s *Server) ListenAndServe(addr string) error { IdleTimeout: 500 * time.Second, } - return srv.ListenAndServe() + return s.srv.ListenAndServe() } -- cgit 1.4.1