INNER CODE UNIT · Go

runningInsideK8s

SeldonIO/seldon-core · scheduler/cmd/agent/main.go:107

func runningInsideK8s() bool {
	return cli.Namespace != ""
}

func termSignalErrHandler(logger *log.Logger, errChan <-chan error) {
	exit := make(chan os.Signal, 1)
	signal.Notify(exit, os.Interrupt, syscall.SIGTERM)

	select {
	case err := <-errChan:
		logger.WithError(err).Error("Shutting down due to error")
	case <-exit:
		logger.Info("Shutting down due to SIGTERM or SIGINT")
	}
}

func main() {
	// we force auto-scaling to be disabled until scale-up issue is resoled

View source record →