Documentation
¶
Overview ¶
Package streams-memory is the In-Memory implementation for Streamhub-based programs.
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var ErrBusNotStarted = errors.New("streams: In-memory bus has not been started")
ErrBusNotStarted The in-memory bus has not been started
Functions ¶
This section is empty.
Types ¶
type Bus ¶
type Bus struct {
// contains filtered or unexported fields
}
Bus is an in-memory message broker to enable interactions between publishers and stream-listeners
type Reader ¶
type Reader struct {
// contains filtered or unexported fields
}
Reader is the streams.Reader in-memory implementation
func (*Reader) ExecuteTask ¶
ExecuteTask starts the stream-listening job using the internal in-memory Bus
type Writer ¶
type Writer struct {
// contains filtered or unexported fields
}
Writer is the streams.Writer in-memory implementation
Source Files
Click to show internal directories.
Click to hide internal directories.