batchengine

Documentation

Index

• type BatchEngine
  • func New(processor goduck.BatchProcessor, maxBatchSize int, maxTimeout time.Duration, ...) *BatchEngine
  • func NewFromEndpoint(e endpoint.Endpoint, decoder goduck.EndpointBatchDecoder, maxBatchSize int, ...) *BatchEngine
  • func (e *BatchEngine) Run(ctx context.Context) error

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

func (*BatchEngine) Run

func (e *BatchEngine) Run(ctx context.Context) error

Run processes the messages and then closes