Skip to main content

ClusterService

vectorizer_protocol::grpc_gen::cluster::cluster_service_server

Trait ClusterService 

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

Show 16 methods    // Required methods
    fn get_cluster_state<'life0, 'async_trait>(
        &'life0 self,
        request: Request<GetClusterStateRequest>,
    ) -> Pin<Box<dyn Future<Output = Result<Response<GetClusterStateResponse>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn update_cluster_state<'life0, 'async_trait>(
        &'life0 self,
        request: Request<UpdateClusterStateRequest>,
    ) -> Pin<Box<dyn Future<Output = Result<Response<UpdateClusterStateResponse>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn remote_insert_vector<'life0, 'async_trait>(
        &'life0 self,
        request: Request<RemoteInsertVectorRequest>,
    ) -> Pin<Box<dyn Future<Output = Result<Response<RemoteInsertVectorResponse>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn remote_update_vector<'life0, 'async_trait>(
        &'life0 self,
        request: Request<RemoteUpdateVectorRequest>,
    ) -> Pin<Box<dyn Future<Output = Result<Response<RemoteUpdateVectorResponse>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn remote_delete_vector<'life0, 'async_trait>(
        &'life0 self,
        request: Request<RemoteDeleteVectorRequest>,
    ) -> Pin<Box<dyn Future<Output = Result<Response<RemoteDeleteVectorResponse>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn remote_search_vectors<'life0, 'async_trait>(
        &'life0 self,
        request: Request<RemoteSearchVectorsRequest>,
    ) -> Pin<Box<dyn Future<Output = Result<Response<RemoteSearchVectorsResponse>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn remote_hybrid_search<'life0, 'async_trait>(
        &'life0 self,
        request: Request<RemoteHybridSearchRequest>,
    ) -> Pin<Box<dyn Future<Output = Result<Response<RemoteHybridSearchResponse>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn remote_create_collection<'life0, 'async_trait>(
        &'life0 self,
        request: Request<RemoteCreateCollectionRequest>,
    ) -> Pin<Box<dyn Future<Output = Result<Response<RemoteCreateCollectionResponse>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn remote_get_collection_info<'life0, 'async_trait>(
        &'life0 self,
        request: Request<RemoteGetCollectionInfoRequest>,
    ) -> Pin<Box<dyn Future<Output = Result<Response<RemoteGetCollectionInfoResponse>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn remote_delete_collection<'life0, 'async_trait>(
        &'life0 self,
        request: Request<RemoteDeleteCollectionRequest>,
    ) -> Pin<Box<dyn Future<Output = Result<Response<RemoteDeleteCollectionResponse>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn health_check<'life0, 'async_trait>(
        &'life0 self,
        request: Request<HealthCheckRequest>,
    ) -> Pin<Box<dyn Future<Output = Result<Response<HealthCheckResponse>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn check_quota<'life0, 'async_trait>(
        &'life0 self,
        request: Request<CheckQuotaRequest>,
    ) -> Pin<Box<dyn Future<Output = Result<Response<CheckQuotaResponse>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn get_shard_vectors<'life0, 'async_trait>(
        &'life0 self,
        request: Request<GetShardVectorsRequest>,
    ) -> Pin<Box<dyn Future<Output = Result<Response<GetShardVectorsResponse>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn raft_vote<'life0, 'async_trait>(
        &'life0 self,
        request: Request<RaftVoteRequest>,
    ) -> Pin<Box<dyn Future<Output = Result<Response<RaftVoteResponse>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn raft_append_entries<'life0, 'async_trait>(
        &'life0 self,
        request: Request<RaftAppendEntriesRequest>,
    ) -> Pin<Box<dyn Future<Output = Result<Response<RaftAppendEntriesResponse>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn raft_snapshot<'life0, 'async_trait>(
        &'life0 self,
        request: Request<RaftSnapshotRequest>,
    ) -> Pin<Box<dyn Future<Output = Result<Response<RaftSnapshotResponse>, 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 ClusterServiceServer.

Required Methods§

Source

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

Get cluster state from a node

Source

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

Update cluster state (heartbeat, membership changes)

Source

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

Remote vector operations

Source

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

Source

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

Source

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

Source

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

Remote collection operations

Source

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

Source

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

Source

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

Health check

Source

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

Quota check across cluster

Source

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

Shard data migration: fetch vectors from a shard in paginated batches

Source

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

Raft consensus RPCs

Source

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

Source

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

Implementors§