daemon

type Daemon interface {
	// GetRunningBackgroundWorkers gets the running background workers.
	GetRunningBackgroundWorkers() []string

	// BackgroundWorker adds a new background worker to the daemon.
	// Use order to define in which shutdown order this particular
	// background worker is shut down (higher = earlier).
	BackgroundWorker(name string, handler WorkerFunc, order ...int) error

	// DebugEnabled allows to configure the daemon to issue log messages for debugging purposes.
	DebugEnabled(enabled bool)

	// Start starts the daemon.
	Start()

	// Run runs the daemon and then waits for the daemon to shutdown.
	Run()

	// Shutdown signals all background worker of the daemon shut down.
	// This call doesn't await termination of the background workers.
	Shutdown()

	// Shutdown signals all background worker of the daemon to shut down and
	// then waits for their termination.
	ShutdownAndWait()

	// IsRunning checks whether the daemon is running.
	IsRunning() bool

	// IsStopped checks whether the daemon was stopped.
	IsStopped() bool

	// ContextStopped returns a context that is done when the deamon is stopped.
	ContextStopped() context.Context
}

type OrderedDaemon struct {
	// contains filtered or unexported fields
}

type WorkerFunc = func(shutdownSignal <-chan struct{})