50 lines
1.2 KiB
Go
50 lines
1.2 KiB
Go
|
package ca
|
||
|
|
|
||
|
|
import (
|
||
|
|
"log"
|
||
|
|
"os"
|
||
|
|
"os/signal"
|
||
|
|
"syscall"
|
||
|
|
)
|
||
|
|
|
||
|
|
// StopReloader is the interface that external commands can implement to stop
|
||
|
|
// the server and reload the configuration while running.
|
||
|
|
type StopReloader interface {
|
||
|
|
Stop() error
|
||
|
|
Reload() error
|
||
|
|
}
|
||
|
|
|
||
|
|
// StopReloaderHandler watches SIGINT, SIGTERM and SIGHUP on a list of servers
|
||
|
|
// implementing the StopReloader interface, and when one of those signals is
|
||
|
|
// caught we'll run Stop (SIGINT, SIGTERM) or Reload (SIGHUP) on all servers.
|
||
|
|
func StopReloaderHandler(servers ...StopReloader) {
|
||
|
|
signals := make(chan os.Signal, 1)
|
||
|
|
signal.Notify(signals, syscall.SIGINT, syscall.SIGTERM, syscall.SIGHUP)
|
||
|
|
defer signal.Stop(signals)
|
||
|
|
|
||
|
|
for {
|
||
|
|
select {
|
||
|
|
case sig := <-signals:
|
||
|
|
switch sig {
|
||
|
|
case syscall.SIGHUP:
|
||
|
|
log.Println("reloading ...")
|
||
|
|
for _, server := range servers {
|
||
|
|
err := server.Reload()
|
||
|
|
if err != nil {
|
||
|
|
log.Printf("error reloading server: %+v", err)
|
||
|
|
}
|
||
|
|
}
|
||
|
|
case syscall.SIGINT, syscall.SIGTERM:
|
||
|
|
log.Println("shutting down ...")
|
||
|
|
for _, server := range servers {
|
||
|
|
err := server.Stop()
|
||
|
|
if err != nil {
|
||
|
|
log.Printf("error stopping server: %s", err.Error())
|
||
|
|
}
|
||
|
|
}
|
||
|
|
return
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|