ConnectionActive returns a ConnectionStatus representing a component connection where we have an active connection.

ConnectionClosed returns a ConnectionStatus representing a component that has intentionally closed its connection.

ConnectionFailing returns a ConnectionStatus representing a component connection where we are attempting to connect to the service but are currently unable due to the provided error.

ConnectionPending returns a ConnectionStatus representing a component that has not yet attempted to establish its connection.

ErrInvalidType creates an error that describes a component type being initialised with an unrecognised implementation.

NoopObservability returns an implementation of Observability that does nothing.

ErrAlreadyStarted is returned when an input or output type gets started a second time.

Manager errors.

Errors used throughout the codebase.

Manager errors.

Manager errors.

Manager errors.

Buffer errors.

Errors used throughout the codebase.

Errors used throughout the codebase.

ErrNotUnwrapped is returned in cases where a component was meant to be unwrapped either from the public packages or to the public packages but for some reason this did not happen.

Manager errors.

Manager errors.

Manager errors.

Manager errors.

Errors used throughout the codebase.

Errors used throughout the codebase.

ConnectionStatus represents the current connection status of a given component.

ErrBackOff is an error returned that allows for a back off duration to be specified.

LabelledError is an error that could be returned by components annotated by their label (or path) in order to provide extra context to which specific component within a config is yielding it.

Observability is an interface implemented by components that provide a range of observability APIs to components.

ConnectionStatuses represents an aggregate of connection statuses.