Struct CapabilityRouter 

pub struct CapabilityRouter { /* private fields */ }

State-aware capability routing engine

Implementations

impl CapabilityRouter

pub fn new() -> Self

pub fn register_local(&mut self, ad: DistributedCapabilityAdvertisement)

Register a local capability

pub fn register_remote(&mut self, ad: DistributedCapabilityAdvertisement)

Register a remote capability

pub fn update_peer_state( &mut self, peer_id: String, namespace: String, version: u64, )

Update peer state version

pub fn get_peer_state_version(&self, peer_id: &str, namespace: &str) -> u64

Get the state version a peer has for a namespace

pub fn route( &self, cap_ref: &CapabilityRef, required_state_version: u64, local_peer_id: &str, ) -> RouteDecision

Route a capability execution request

pub fn find_compatible_providers( &self, cap_ref: &CapabilityRef, required_state_version: u64, ) -> Vec<&DistributedCapabilityAdvertisement>

Find providers with compatible state versions

pub fn requires_state_acquisition( &self, provider_peer: &str, cap_ref: &CapabilityRef, required_state_version: u64, ) -> bool

Check if capability requires state acquisition

pub fn plan_state_acquisition( &self, provider_peer: &str, cap_ref: &CapabilityRef, required_state_version: u64, ) -> Vec<String>

Plan state acquisition - list namespaces that need to be acquired

Trait Implementations

impl Default for CapabilityRouter

fn default() -> Self

Returns the “default value” for a type.