Struct EventProcessorBuilder 

pub struct EventProcessorBuilder { /* private fields */ }

Builder for continuous event processors

Example

let processor = EventProcessorBuilder::new(db)
    .with_handler(DepositHandler)
    .with_handler(WithdrawHandler)
    .with_poll_interval(Duration::from_millis(100))
    .with_error_strategy(ErrorStrategy::LogAndSkip)
    .build()?;

processor.run().await?;

Implementations

impl EventProcessorBuilder

pub fn new(db: Arc<AzothDb>) -> Self

Create a new event processor builder

pub fn with_handler(self, handler: Box<dyn EventHandler>) -> Self

Register an event handler

pub fn with_poll_interval(self, interval: Duration) -> Self

Set the poll interval (how often to check for new events)

pub fn with_batch_size(self, size: usize) -> Self

Set the batch size (how many events to process at once)

pub fn with_error_strategy(self, strategy: ErrorStrategy) -> Self

Set the error handling strategy

pub fn with_dead_letter_queue(self, dlq: Arc<DeadLetterQueue>) -> Self

Enable dead letter queue

pub fn build(self, conn: Arc<Connection>) -> EventProcessor

Build the event processor