Versions in this module Expand all Collapse all v4 v4.14.1 Apr 26, 2023 Changes in this version + var ErrNoStore = errors.New("result store not found within batch context") + func AddResultStore(msg message.Batch, store ResultStore) + func SetAsResponse(msg message.Batch) error + type ResultStore interface + Add func(msg message.Batch) + Clear func() + Get func() []message.Batch + func NewResultStore() ResultStore + type ResultStoreKeyType int + const ResultStoreKey + type Tracked struct + func NewTracked(msg message.Batch, ackFn func(context.Context, error) error) *Tracked + func (t *Tracked) Ack(ctx context.Context, err error) error + func (t *Tracked) Message() message.Batch Other modules containing this package github.com/dafanshu/benthos/v3
Go to main page