Struct AtlasService 

pub struct AtlasService { /* private fields */ }

Implementations

impl AtlasService

pub fn new(registry: Arc<AtlasRegistry>) -> Self

Trait Implementations

impl Atlas for AtlasService

fn register_primitive<'life0, 'async_trait>( &'life0 self, req: Request<RegisterRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<RegisterResponse>, Status>> + Send + 'async_trait>>

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

Registration – one RPC per CapabilityProvider kind.

fn register_service<'life0, 'async_trait>( &'life0 self, req: Request<RegisterRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<RegisterResponse>, Status>> + Send + 'async_trait>>

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

fn register_skill<'life0, 'async_trait>( &'life0 self, req: Request<RegisterRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<RegisterResponse>, Status>> + Send + 'async_trait>>

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

fn unregister<'life0, 'async_trait>( &'life0 self, req: Request<UnregisterRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<UnregisterResponse>, Status>> + Send + 'async_trait>>

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

fn heartbeat<'life0, 'async_trait>( &'life0 self, req: Request<HeartbeatRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<HeartbeatResponse>, Status>> + Send + 'async_trait>>

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

Liveness + lifecycle.

fn set_lifecycle_state<'life0, 'async_trait>( &'life0 self, req: Request<SetLifecycleStateRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<SetLifecycleStateResponse>, Status>> + Send + 'async_trait>>

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

fn declare_capability<'life0, 'async_trait>( &'life0 self, req: Request<DeclareCapabilityRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<DeclareCapabilityResponse>, Status>> + Send + 'async_trait>>

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

Capability binding.

fn query<'life0, 'async_trait>( &'life0 self, req: Request<QueryRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<QueryResponse>, Status>> + Send + 'async_trait>>

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

Discovery – one Query RPC, kind carried in the request body. Consumers wanting a flat capability list flatten CapabilityProvider.capabilities themselves; each Capability already carries provider_id / provider_kind.

fn connect_capability<'life0, 'async_trait>( &'life0 self, req: Request<ConnectCapabilityRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<ConnectCapabilityResponse>, Status>> + Send + 'async_trait>>

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

Channels.

fn disconnect_capability<'life0, 'async_trait>( &'life0 self, req: Request<DisconnectCapabilityRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<DisconnectCapabilityResponse>, Status>> + Send + 'async_trait>>

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

fn inspect_atlas<'life0, 'async_trait>( &'life0 self, _req: Request<InspectAtlasRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<InspectAtlasResponse>, Status>> + Send + 'async_trait>>

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

Debug.

fn query_contract<'life0, 'async_trait>( &'life0 self, req: Request<QueryContractRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<QueryContractResponse>, Status>> + Send + 'async_trait>>

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

Contracts.

fn list_contracts<'life0, 'async_trait>( &'life0 self, req: Request<ListContractsRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<ListContractsResponse>, Status>> + Send + 'async_trait>>

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

impl Debug for AtlasService

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.