package
3.65.6
Repository: https://github.com/dafanshu/benthos.git
Documentation: pkg.go.dev

# Functions

FieldSpec returns a spec for a common batching field.
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.

# 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.