package
0.26.2
Repository: https://github.com/nwest1/benthos.git
Documentation: pkg.go.dev

# Functions

NewMemory creates a memory based parallel buffer.

# Structs

Memory is a parallel buffer implementation that allows multiple parallel consumers to read and purge messages from the buffer asynchronously.

# Type aliases

AckFunc is a func returned when a message is read from a parallel buffer.