Merge pull request #828 from enj/enj/i/supervisor_graceful_exit
supervisor: ensure graceful exit
This commit is contained in:
commit
d2dfe3634a
@ -14,6 +14,7 @@ import (
|
|||||||
"os"
|
"os"
|
||||||
"os/signal"
|
"os/signal"
|
||||||
"strings"
|
"strings"
|
||||||
|
"syscall"
|
||||||
"time"
|
"time"
|
||||||
|
|
||||||
appsv1 "k8s.io/api/apps/v1"
|
appsv1 "k8s.io/api/apps/v1"
|
||||||
@ -78,7 +79,7 @@ func start(ctx context.Context, l net.Listener, handler http.Handler) {
|
|||||||
|
|
||||||
func waitForSignal() os.Signal {
|
func waitForSignal() os.Signal {
|
||||||
signalCh := make(chan os.Signal, 1)
|
signalCh := make(chan os.Signal, 1)
|
||||||
signal.Notify(signalCh, os.Interrupt)
|
signal.Notify(signalCh, os.Interrupt, syscall.SIGTERM)
|
||||||
return <-signalCh
|
return <-signalCh
|
||||||
}
|
}
|
||||||
|
|
||||||
|
Loading…
Reference in New Issue
Block a user