Trait nakadion::BatchHandler

pub trait BatchHandler {
    fn handle(&self, event_type: EventType, events: &[u8]) -> ProcessingStatus;
}

Required Methods

fn handle(&self, event_type: EventType, events: &[u8]) -> ProcessingStatus

Handle the events.

Calling this method may never panic!

Implementors

• impl<T, E> BatchHandler for T where
    T: TypedBatchHandler<Event = E>,
    E: DeserializeOwned,