View Source Broadway.BatchInfo (Broadway v1.0.7)
A struct used to hold information about a generated batch.
An instance of this struct containing the related info will
be passed to the Broadway.handle_batch/4
callback of the
module implementing the Broadway
behaviour.
See the documentation for %Broadway.BatchInfo{}
for information on the fields.
Link to this section Summary
Functions
The batch info struct.
Link to this section Types
@type t() :: %Broadway.BatchInfo{ batch_key: term(), batcher: atom(), partition: non_neg_integer() | nil, size: pos_integer(), trigger: atom() }
The type for a batch info struct.
Link to this section Functions
The batch info struct.
The fields are:
:batcher
- is the key that defined the batcher. This value can be set in theBroadway.handle_message/3
callback usingBroadway.Message.put_batcher/2
.:batch_key
- identifies the batch key for this batch. SeeBroadway.Message.put_batch_key/2
.:partition
- the partition, if present.:size
- the number of messages in the batch.:trigger
- the trigger that generated the batch, like:timeout
or:flush
.