Skip to main content

Atlas

robonix_atlas::pb::atlas_server

Trait Atlas 

Source 
pub trait Atlas:
    Send
    + Sync
    + 'static {

Show 13 methods    // Required methods
    fn register_primitive<'life0, 'async_trait>(
        &'life0 self,
        request: Request<RegisterRequest>,
    ) -> Pin<Box<dyn Future<Output = Result<Response<RegisterResponse>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn register_service<'life0, 'async_trait>(
        &'life0 self,
        request: 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,
        request: 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,
        request: 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,
        request: Request<HeartbeatRequest>,
    ) -> Pin<Box<dyn Future<Output = Result<Response<HeartbeatResponse>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn set_lifecycle_state<'life0, 'async_trait>(
        &'life0 self,
        request: 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,
        request: Request<DeclareCapabilityRequest>,
    ) -> Pin<Box<dyn Future<Output = Result<Response<DeclareCapabilityResponse>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn query<'life0, 'async_trait>(
        &'life0 self,
        request: Request<QueryRequest>,
    ) -> Pin<Box<dyn Future<Output = Result<Response<QueryResponse>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn connect_capability<'life0, 'async_trait>(
        &'life0 self,
        request: Request<ConnectCapabilityRequest>,
    ) -> Pin<Box<dyn Future<Output = Result<Response<ConnectCapabilityResponse>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn disconnect_capability<'life0, 'async_trait>(
        &'life0 self,
        request: Request<DisconnectCapabilityRequest>,
    ) -> Pin<Box<dyn Future<Output = Result<Response<DisconnectCapabilityResponse>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn query_contract<'life0, 'async_trait>(
        &'life0 self,
        request: Request<QueryContractRequest>,
    ) -> Pin<Box<dyn Future<Output = Result<Response<QueryContractResponse>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn list_contracts<'life0, 'async_trait>(
        &'life0 self,
        request: Request<ListContractsRequest>,
    ) -> Pin<Box<dyn Future<Output = Result<Response<ListContractsResponse>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn inspect_atlas<'life0, 'async_trait>(
        &'life0 self,
        request: Request<InspectAtlasRequest>,
    ) -> Pin<Box<dyn Future<Output = Result<Response<InspectAtlasResponse>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;

}
Expand description

Generated trait containing gRPC methods that should be implemented for use with AtlasServer.

Required Methods§

Source

fn register_primitive<'life0, 'async_trait>( &'life0 self, request: 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.

Source

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

Source

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

Source

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

Source

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

Liveness + lifecycle.

Source

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

Source

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

Capability binding.

Source

fn query<'life0, 'async_trait>( &'life0 self, request: 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.

Source

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

Channels.

Source

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

Source

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

Contracts.

Source

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

Source

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

Debug.

Implementors§