Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type BatchEngine ¶
type BatchEngine struct {
// contains filtered or unexported fields
}
BatchEngine is an engine that processes a batch of messages only once and then shuts down
func New ¶
func New( processor goduck.BatchProcessor, maxBatchSize int, maxTimeout time.Duration, stream goduck.Stream, ) *BatchEngine
New creates a new BatchEngine.
func NewFromEndpoint ¶
func NewFromEndpoint( e endpoint.Endpoint, decoder goduck.EndpointBatchDecoder, maxBatchSize int, maxTimeout time.Duration, stream goduck.Stream, ) *BatchEngine
NewFromEndpoint creates a BatchProcessor from a go-kit endpoint
Source Files
Click to show internal directories.
Click to hide internal directories.