package
1.3.0
Repository: https://github.com/warpstreamlabs/bento.git
Documentation: pkg.go.dev

# Functions

AddResultStore sets a result store within the context of the provided message that allows a roundtrip.Writer or any other component to propagate a resulting message back to the origin.
AddResultStoreMsg sets a result store within the context of the provided message that allows a roundtrip.Writer or any other component to propagate a resulting message back to the origin.
NewResultStore returns an implementation of ResultStore.
NewTracked creates a transaction from a message batch and a response channel.
SetAsResponse takes a mutated message and stores it as a response message, this action fails if the message does not contain a valid ResultStore within its context.

# Constants

ResultStoreKey is the recommended key value for adding ResultStores to a message context.

# Variables

ErrNoStore is an error returned by components attempting to write a message batch to a ResultStore but are unable to locate the store within the batch context.

# Structs

Tracked is a transaction type that adds identifying tags to messages such that an error returned resulting from multiple transaction messages can be reduced.

# Interfaces

ResultStore is a type designed to be propagated along with a message as a way for an output destination to store the final version of the message payload as it saw it.

# Type aliases

ResultStoreKeyType is the recommended type of a context key for adding ResultStores to a message context.