# Functions
LoadStreamConfigsFromDirectory reads a map of stream ids to configurations by walking a directory of .json and .yaml files.
New creates a new stream manager.Type.
NewStreamStatus creates a new StreamStatus.
OptAddInputPipelines adds pipeline constructors that will be called for every new stream and attached to the input component.
OptAddOutputPipelines adds pipeline constructors that will be called for every new stream and attached to the output component.
OptAddProcessors adds processor constructors that will be called for every new stream and attached to the processor pipelines.
OptSetAPITimeout sets the default timeout for HTTP API requests.
OptSetLogger sets the logging output to be used by the manager and all child streams.
OptSetManager sets the service manager to be used by the stream manager and all child streams.
OptSetStats sets the metrics aggregator to be used by the manager and all child streams.
# Variables
Errors specifically returned by a stream manager.
Errors specifically returned by a stream manager.
# Structs
StreamStatus tracks a stream along with information regarding its internals.
Type manages a collection of streams, providing APIs for CRUD operations on the streams.
# Type aliases
ConfigSet is a map of stream configurations mapped by ID, which can be YAML parsed without losing default values inside the stream configs.
StreamPipeConstructorFunc is a closure type that constructs a pipeline type for new streams, where the id of the stream is provided as an argument.
StreamProcConstructorFunc is a closure type that constructs a processor type for new streams, where the id of the stream is provided as an argument.