Struct CapabilityResolver 

pub struct CapabilityResolver { /* private fields */ }

Resolves local and discovered providers and enforces capability requirements.

Implementations

impl CapabilityResolver

pub fn new(registry: CapabilityRegistry) -> Self

Creates a resolver backed by a local registry.

pub fn with_peers(self, peers: Vec<PeerRecord>) -> Self

Adds the current discovery snapshot used for remote resolution.

pub fn with_selector(self, selector: Arc<dyn CapabilitySelectionPolicy>) -> Self

Replaces the default provider selection policy.

pub fn resolve( &self, identity: &CoreIdentity, service_id: &ServiceId, request: &CapabilityRequest, leadership: Option<&dyn ServiceLeadershipGuard>, now_ms: u64, ) -> CapabilityResult<CapabilityProvider>

Resolves a provider and checks leadership for the declared service.

pub fn handle_local( &self, identity: &CoreIdentity, service_id: &ServiceId, request: &CapabilityRequest, leadership: Option<&dyn ServiceLeadershipGuard>, now_ms: u64, ) -> CapabilityResult<CapabilityResponse>

Handles a local capability using service-scoped leadership.

pub fn handle( &self, identity: &CoreIdentity, service_id: &ServiceId, request: &CapabilityRequest, leadership: Option<&dyn ServiceLeadershipGuard>, remote_invoker: Option<&dyn RemoteCapabilityInvoker>, now_ms: u64, ) -> CapabilityResult<CapabilityResponse>

Handles a local or remote capability using service-scoped leadership.

pub fn handle_owned( &self, identity: &CoreIdentity, service_id: &ServiceId, request: CapabilityRequest, leadership: Option<&dyn ServiceLeadershipGuard>, remote_invoker: Option<&dyn RemoteCapabilityInvoker>, now_ms: u64, ) -> CapabilityResult<CapabilityResponse>

Handles an owned local or remote request using service-scoped leadership.

Local handlers retain their borrowed contract. A remote invoker may transfer the request fields directly into its transport.