package
2.15.1+incompatible
Repository: https://github.com/jeffail/benthos.git
Documentation: pkg.go.dev
# Functions
NewPolicy creates an empty policy with default rules.
NewPolicyConfig creates a default PolicyConfig.
SanitisePolicyConfig returns a policy config structure ready to be marshalled with irrelevant fields omitted.
# Variables
PolicyDoc is a markdown document explaining the fields of a Benthos batch policy.
# Structs
Policy implements a batching policy by buffering messages until, based on a set of rules, the buffered messages are ready to be sent onwards as a batch.
PolicyConfig contains configuration parameters for a batch policy.