shutdown

mgr := shutdown.New(shutdown.WithBudget(30 * time.Second))

srv := &http.Server{Addr: ":8080", Handler: r}
_ = shutdownnethttp.Register(mgr, srv)

_ = mgr.Register("db",    closeFn(db.Close),  shutdown.WithPhase(shutdown.PhaseCloseClients))
_ = mgr.Register("redis", closeFn(rdb.Close), shutdown.WithPhase(shutdown.PhaseCloseClients))

go func() { _ = srv.ListenAndServe() }()
_ = mgr.Listen(ctx)

stop := make(chan struct{})

handle, _ := mgr.RegisterActor("worker", func(_ error) {
    close(stop) // tell the run loop to exit
}, shutdown.WithActorPhase(shutdown.PhaseDrainTraffic))

go func() {
    err := worker.Run(stop) // blocks until stop is closed
    handle.Done(err)         // tells the manager the actor finished
}()

mux.HandleFunc("/admin/shutdown", func(w http.ResponseWriter, r *http.Request) {
    if !authorized(r) { w.WriteHeader(http.StatusForbidden); return }
    go func() {
        _ = mgr.Shutdown(context.Background()) // same execution path as a signal
    }()
    w.WriteHeader(http.StatusAccepted)
})

mgr.OnSignal(syscall.SIGHUP, func(ctx context.Context, _ os.Signal) {
    if err := config.Reload(); err != nil {
        log.Println("reload failed:", err)
    }
})
mgr.OnSignal(syscall.SIGUSR1, func(ctx context.Context, _ os.Signal) {
    rotateLogFile()
})