Struct DefaultDispatcher 

pub struct DefaultDispatcher { /* private fields */ }

Default implementation of the Dispatcher trait

Implementations

impl DefaultDispatcher

pub fn new() -> Self

Create a new dispatcher with empty registries

pub fn with_registries( connector_registry: ConnectorRegistry, type_registry: DataObjectTypeRegistry, ) -> Self

Create a dispatcher with existing registries

Trait Implementations

impl Default for DefaultDispatcher

fn default() -> Self

Returns the “default value” for a type.

impl Dispatcher for DefaultDispatcher

fn register_connector<'life0, 'life1, 'async_trait>( &'life0 mut self, object_type: &'life1 str, connector: Box<dyn Connector>, ) -> Pin<Box<dyn Future<Output = NirvResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Register a connector for a specific data object type

fn route_query<'life0, 'life1, 'async_trait>( &'life0 self, query: &'life1 InternalQuery, ) -> Pin<Box<dyn Future<Output = NirvResult<Vec<ConnectorQuery>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Route a query to appropriate connectors based on data object types

fn execute_distributed_query<'life0, 'async_trait>( &'life0 self, queries: Vec<ConnectorQuery>, ) -> Pin<Box<dyn Future<Output = NirvResult<QueryResult>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Execute a distributed query across multiple connectors

fn list_available_types(&self) -> Vec<String>

List all available data object types

fn is_type_registered(&self, object_type: &str) -> bool

Check if a data object type is registered

fn get_connector(&self, object_type: &str) -> Option<&dyn Connector>

Get connector for a specific data object type