Struct DistributedCapabilityRegistry 

pub struct DistributedCapabilityRegistry { /* private fields */ }

Implementations

impl DistributedCapabilityRegistry

pub fn new() -> Self

pub fn empty() -> Self

pub fn register_toolset( &self, reference: ToolsetRef, registry: ToolRegistry, ) -> Result<(), DistributedCapabilityError>

pub fn register_llm_client( &self, reference: CapabilityRef, client: Arc<dyn LlmClient>, )

pub fn register_workspace_backend( &self, reference: CapabilityRef, backend: Arc<dyn WorkspaceBackend>, )

pub fn register_approval_provider( &self, reference: CapabilityRef, provider: Arc<dyn ApprovalProvider>, )

pub fn register_approval_broker( &self, reference: CapabilityRef, broker: ApprovalBroker, )

pub fn register_cancellation( &self, reference: CapabilityRef, token: CancellationToken, )

pub fn register_event_sink( &self, reference: CapabilityRef, sink: RuntimeEventHandler, )

pub fn register_host_cost_meter( &self, reference: CapabilityRef, meter: Arc<dyn HostCostMeter>, )

pub fn register_app_state( &self, reference: CapabilityRef, state: Arc<dyn Any + Send + Sync>, )

pub fn register_memory_provider( &self, reference: CapabilityRef, provider: Arc<dyn MemoryProvider>, )

pub fn register_hook( &self, reference: CapabilityRef, hook: Arc<dyn RuntimeHook>, )

pub fn register_observer( &self, reference: CapabilityRef, observer: RuntimeEventHandler, )

pub fn register_sub_task_manager( &self, reference: CapabilityRef, manager: SubTaskManager, )

pub fn register_tool_predicate( &self, reference: CapabilityRef, predicate: CanUseToolPredicate, )

pub fn register_checkpoint_store( &self, reference: CapabilityRef, store: Arc<dyn CheckpointStoreV2>, )

pub fn register_checkpoint_event_store( &self, reference: CapabilityRef, store: Arc<dyn IdempotentRunEventStore>, )

pub fn register_checkpoint_extension( &self, reference: CapabilityRef, extension: Arc<dyn CheckpointExtension>, )

pub fn register_reconciliation_provider( &self, reference: CapabilityRef, provider: Arc<dyn ReconciliationProvider>, )

pub fn resolve( &self, capabilities: &DistributedCapabilities, ) -> Result<ResolvedDistributedCapabilities, DistributedCapabilityError>

Trait Implementations

impl Clone for DistributedCapabilityRegistry

fn clone(&self) -> DistributedCapabilityRegistry

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Default for DistributedCapabilityRegistry

fn default() -> Self

Returns the “default value” for a type.