Struct EventRouterBuilder 

pub struct EventRouterBuilder<S> { /* private fields */ }

Builder for constructing an event router.

Use the on_create, on_update, on_delete, and on methods to register handlers, then call build to produce a dispatch function compatible with AtrgApp::on_event.

Implementations

impl<S: Clone + Send + Sync + 'static> EventRouterBuilder<S>

pub fn new() -> Self

Create a new empty router builder.

pub fn on_create<F, Fut>( self, collection: impl Into<String>, handler: F, ) -> Self

where F: Fn(CommitEvent, S) -> Fut + Send + Sync + 'static, Fut: Future<Output = Result<()>> + Send + 'static,

Register a handler for create operations on a collection.

pub fn on_update<F, Fut>( self, collection: impl Into<String>, handler: F, ) -> Self

where F: Fn(CommitEvent, S) -> Fut + Send + Sync + 'static, Fut: Future<Output = Result<()>> + Send + 'static,

Register a handler for update operations on a collection.

pub fn on_delete<F, Fut>( self, collection: impl Into<String>, handler: F, ) -> Self

where F: Fn(CommitEvent, S) -> Fut + Send + Sync + 'static, Fut: Future<Output = Result<()>> + Send + 'static,

Register a handler for delete operations on a collection.

pub fn on<F, Fut>(self, collection: impl Into<String>, handler: F) -> Self

where F: Fn(CommitEvent, S) -> Fut + Send + Sync + 'static, Fut: Future<Output = Result<()>> + Send + 'static,

Register a handler for ALL operations on a collection.

The handler will be called for create, update, and delete events on the specified collection.

pub fn build( self, ) -> impl Fn(JetstreamEvent, S) -> BoxFuture<'static, Result<()>> + Send + Sync + 'static

Build the router into a dispatch function compatible with AtrgApp::on_event.

The returned closure can be passed directly to AtrgApp::on_event(...). Events that don’t match any registered route are silently ignored (with a tracing::debug! log).

Trait Implementations

impl<S: Clone + Send + Sync + 'static> Default for EventRouterBuilder<S>

fn default() -> Self

Returns the “default value” for a type.