package
1.3.0
Repository: https://github.com/warpstreamlabs/bento.git
Documentation: pkg.go.dev

# Functions

New creates a new stream manager.Type.
OptAPIEnabled sets whether the stream manager registers API endpoints for CRUD operations on 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

StreamProcConstructorFunc is a closure type that constructs a processor type for new streams, where the id of the stream is provided as an argument.