Trait nakadion::BatchHandler

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

Required Methods

fn handle(&mut 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,