Documentation
¶
Overview ¶
Package service defines types and interfaces for long-running services that can be started and shut down.
TODO(a.garipov): Add tests.
Index ¶
Constants ¶
const SignalHandlerPrefix = "sighdlr"
SignalHandlerPrefix is the default and recommended prefix for the logger of a SignalHandler.
const SignalHandlerShutdownTimeout = 10 * time.Second
SignalHandlerShutdownTimeout is the default shutdown timeout for all services in a SignalHandler.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Empty ¶
type Empty struct{}
Empty is an Interface implementation that does nothing and returns nil.
type Interface ¶
type Interface interface {
// Start starts the service. ctx is used for cancelation.
//
// It is recommended that Start returns only after the service has
// completely finished its initialization. If that cannot be done, the
// implementation of Start must document that.
Start(ctx context.Context) (err error)
// Shutdown gracefully stops the service. ctx is used to determine
// a timeout before trying to stop the service less gracefully.
//
// It is recommended that Shutdown returns only after the service has
// completely finished its termination. If that cannot be done, the
// implementation of Shutdown must document that.
Shutdown(ctx context.Context) (err error)
}
Interface is the interface for long-running services.
type SignalHandler ¶
type SignalHandler struct {
// contains filtered or unexported fields
}
SignalHandler processes incoming signals and shuts services down.
TODO(a.garipov): Expand to Windows.
func NewSignalHandler ¶
func NewSignalHandler(c *SignalHandlerConfig) (h *SignalHandler)
NewSignalHandler returns a new properly initialized *SignalHandler that shuts down services. If c is nil, the defaults of SignalHandlerConfig are used.
func (*SignalHandler) Add ¶
func (h *SignalHandler) Add(svcs ...Interface)
Add adds a services to the signal handler.
It must not be called concurrently with [Handle].
func (*SignalHandler) Handle ¶
func (h *SignalHandler) Handle(ctx context.Context) (status osutil.ExitCode)
Handle processes signals from the handler's osutil.SignalNotifier. It blocks until a termination signal is received, after which it shuts down all services. ctx is used for logging and serves as the base for the shutdown timeout. status is osutil.ExitCodeSuccess on success and osutil.ExitCodeFailure on error.
Handle must not be called concurrently with [Add].
type SignalHandlerConfig ¶
type SignalHandlerConfig struct {
// SignalNotifier is used to notify the handler about signals.
//
// If nil, [osutil.DefaultSignalNotifier] is used.
SignalNotifier osutil.SignalNotifier
// Logger is used for logging the shutting down of services. It should
// include a prefix; the recommended prefix is [SignalHandlerPrefix].
//
// If nil, [slog.Default] with [SignalHandlerPrefix] is used.
Logger *slog.Logger
// ShutdownTimeout is the timeout used to shut down all services gracefully.
//
// If zero, [DefaultShutdownTimeout] is used.
ShutdownTimeout time.Duration
}
SignalHandlerConfig contains the configuration for a signal handler. See NewSignalHandler.
Source Files