Struct DispatcherBuilder 

pub struct DispatcherBuilder {
    routes: Vec<Route>,
    config: DispatcherConfig,
    k2k_config: K2KConfig,
}

Builder for creating a KernelDispatcher.

Fields

routes: Vec<Route>

config: DispatcherConfig

k2k_config: K2KConfig

Implementations

impl DispatcherBuilder

pub fn new() -> DispatcherBuilder

Create a new builder.

pub fn route<M>(self, kernel_id: KernelId) -> DispatcherBuilder

where M: PersistentMessage,

Add a route for a PersistentMessage type.

pub fn route_named<M>( self, kernel_id: KernelId, handler_name: &str, ) -> DispatcherBuilder

where M: PersistentMessage,

Add a route with custom handler name.

pub fn route_raw(self, type_id: u64, kernel_id: KernelId) -> DispatcherBuilder

Add a raw route (for dynamic type_ids).

pub fn with_config(self, config: DispatcherConfig) -> DispatcherBuilder

Set dispatcher configuration.

pub fn with_k2k_config(self, config: K2KConfig) -> DispatcherBuilder

Set K2K configuration.

pub fn with_logging(self) -> DispatcherBuilder

Enable logging.

pub fn with_priority(self, priority: u8) -> DispatcherBuilder

Set default message priority.

pub fn build(self) -> KernelDispatcher

Build the dispatcher with a new K2K broker.

pub fn build_with_broker(self, broker: Arc<K2KBroker>) -> KernelDispatcher

Build the dispatcher with an existing K2K broker.

Trait Implementations

impl Default for DispatcherBuilder

fn default() -> DispatcherBuilder

Returns the “default value” for a type.