Trait nakadion::HandlerFactory

pub trait HandlerFactory {
    type Handler: BatchHandler + Send + 'static;
    fn create_handler(
        &self, 
        partition: &PartitionId
    ) -> Result<Self::Handler, CreateHandlerError>;
}

Associated Types

type Handler: BatchHandler + Send + 'static

Required Methods

fn create_handler(
    &self,
    partition: &PartitionId
) -> Result<Self::Handler, CreateHandlerError>

Implementors