GraphRpcService

ruvector_graph::distributed::rpc

Trait GraphRpcService 

Source 
pub trait GraphRpcService: Send + Sync {
    // Required methods
    fn execute_query<'life0, 'async_trait>(
        &'life0 self,
        request: ExecuteQueryRequest,
    ) -> Pin<Box<dyn Future<Output = Result<ExecuteQueryResponse, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn replicate_data<'life0, 'async_trait>(
        &'life0 self,
        request: ReplicateDataRequest,
    ) -> Pin<Box<dyn Future<Output = Result<ReplicateDataResponse, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn health_check<'life0, 'async_trait>(
        &'life0 self,
        request: HealthCheckRequest,
    ) -> Pin<Box<dyn Future<Output = Result<HealthCheckResponse, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn get_shard_info<'life0, 'async_trait>(
        &'life0 self,
        request: GetShardInfoRequest,
    ) -> Pin<Box<dyn Future<Output = Result<GetShardInfoResponse, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
}
Expand description

Graph RPC service trait (would be implemented via tonic in production)

Required Methods§

Source

fn execute_query<'life0, 'async_trait>( &'life0 self, request: ExecuteQueryRequest, ) -> Pin<Box<dyn Future<Output = Result<ExecuteQueryResponse, Status>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

Execute a query on this node

Source

fn replicate_data<'life0, 'async_trait>( &'life0 self, request: ReplicateDataRequest, ) -> Pin<Box<dyn Future<Output = Result<ReplicateDataResponse, Status>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

Replicate data to this node

Source

fn health_check<'life0, 'async_trait>( &'life0 self, request: HealthCheckRequest, ) -> Pin<Box<dyn Future<Output = Result<HealthCheckResponse, Status>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

Health check

Source

fn get_shard_info<'life0, 'async_trait>( &'life0 self, request: GetShardInfoRequest, ) -> Pin<Box<dyn Future<Output = Result<GetShardInfoResponse, Status>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

Get shard information

Implementors§