Struct EventProcessor 

pub struct EventProcessor { /* private fields */ }

Continuous event processor

Runs in the background, continuously consuming events and routing them to registered handlers.

Implementations

impl EventProcessor

pub fn builder(db: Arc<AzothDb>) -> EventProcessorBuilder

Create a new builder

pub async fn run(&mut self) -> Result<()>

Run the processor until shutdown is signaled

This is an async function that runs continuously, polling for new events and processing them through registered handlers.

pub fn run_blocking(&mut self) -> Result<()>

Run the processor synchronously (blocking)

Useful for single-threaded applications or testing.

pub fn process_batch(&mut self) -> Result<usize>

Process a single batch of events

Returns the number of events processed.

pub fn shutdown(&self)

Signal graceful shutdown

pub fn shutdown_handle(&self) -> ShutdownHandle

Get a handle for shutting down the processor

pub fn cursor(&self) -> u64

Get the current cursor position

pub fn lag(&self) -> Result<u64>

Get the event lag (how many events behind the tip)