multistream_batch/
lib.rs

1/*!
2Implementations of batching algorithms.
3
4Batching works by accumulating items and later automatically flushing them all together when the batch has reached a limit.
5All items collected in the single batch are available at once for further processing (e.g. batch insert into a database).
6
7These implementations will construct batches based on:
8* limit of the number of items collected in a batch,
9* limit of time duration since the first item appended to the batch,
10* calling one of the batch consuming methods,
11* sending flush command between batch items (channel-based implementations).
12
13See sub modules for documentation of available algorithms.
14!*/
15
16pub mod buf_batch;
17#[cfg(feature = "crossbeam-channel")]
18pub mod channel;
19pub mod multi_buf_batch;