//
pkg.gl
Category
github.com/warpstreamlabs/bento
internal
batch
policy
package
1.3.0
Repository:
https://github.com/warpstreamlabs/bento.git
Documentation:
pkg.go.dev
Overview
Versions
1
Dependencies
13
Dependents
5
Files
251 SLOC
#
Packages
batchconfig
No description provided by the author
#
Functions
FieldSpec
FieldSpec returns a spec for a common batching field.
New
New creates an empty policy with default rules.
#
Structs
Batcher
Batcher 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.