crates/common/batcher/src/batchable.rs


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17

use chrono::{DateTime, Utc};
use std::fmt::Debug;
use std::hash::Hash;

/// Implement this interface for the items that you want batched.
/// No items with the same key will go in the same batch.
/// The event_time of the item will determine how items are grouped,
/// dependent on how the batcher is configured.
pub trait Batchable {
    type Key: Eq + Hash + Debug;

    /// Define the uniqueness within a batch.
    fn key(&self) -> Self::Key;

    /// The time at which this item was created. This time is used to group items into a batch.
    fn event_time(&self) -> DateTime<Utc>;
}