CombineStoppables returns a single Stoppable that will call each provided Stoppable in the order they are specified on a Stop.

CreateLogger from a CLI context and a stream config.

CreateManager from a CLI context and a stream config.

DelayShutdown attempts to block until either: - The delay period ends - The provided context is cancelled - The process receives an interrupt or sigterm.

NewSwappableStopper creates a new swappable stopper resource around an initial stoppable.

ReadConfig attempts to read a general service wide config via a returned config.Reader based on input CLI flags.

RunManagerUntilStopped will run the provided HTTP server and block until either a provided stream stoppable is gracefully terminated (via the dataStreamClosedChan) or a signal is given to the process to terminate, at which point the provided HTTP server, the manager, and the stoppable is stopped according to the configured shutdown timeout.

RunService runs a service command (either the default or the streams subcommand).

StoppableManager wraps a manager and API type that potentially outlives one or more dependent streams and encapsulates the logic for shutting them down within the deadline of a given context.

SwappableStopper wraps an active Stoppable resource in a mechanism that allows changing the resource for something else after stopping it.

Stoppable represents a resource (a Bento stream) that can be stopped.