Struct ClusterServiceClient

pub struct ClusterServiceClient<T> { /* private fields */ }

Expand description

Cluster service for inter-server communication

Implementations§

Attempt to create a new client by connecting to a given endpoint.

Compress requests with the given encoding.

This requires the server to support it otherwise it might respond with an error.

Enable decompressing responses.

Limits the maximum size of a decoded message.

Default: 4MB

Limits the maximum size of an encoded message.

Default: usize::MAX

Get cluster state from a node

Update cluster state (heartbeat, membership changes)

Remote vector operations

Remote collection operations

Health check

Quota check across cluster

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

Raft consensus RPCs

Trait Implementations§

Returns a duplicate of the value. Read more

Performs copy-assignment from source. Read more

Formats the value using the given formatter. Read more

Auto Trait Implementations§

Blanket Implementations§

Gets the TypeId of self. Read more

Immutably borrows from an owned value. Read more

Mutably borrows from an owned value. Read more

🔬This is a nightly-only experimental API. (clone_to_uninit)

Performs copy-assignment from self to dest. Read more

Returns the argument unchanged.

Converts to this type from a reference to the input type.

Instruments this type with the provided Span, returning an Instrumented wrapper. Read more

Instruments this type with the current Span, returning an Instrumented wrapper. Read more

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Wrap the input message T in a tonic::Request

Applies the layer to a service and wraps it in Layered.

The resulting type after obtaining ownership.

Creates owned data from borrowed data, usually by cloning. Read more

Uses borrowed data to replace owned data, usually by cloning. Read more

The type returned in the event of a conversion error.

Performs the conversion.

The type returned in the event of a conversion error.

Performs the conversion.

Attaches the provided Subscriber to this type, returning a WithDispatch wrapper. Read more

Attaches the current default Subscriber to this type, returning a WithDispatch wrapper. Read more

Struct ClusterServiceClient Copy item path

Implementations§

impl ClusterServiceClient<Channel>

pub async fn connect<D>(dst: D) -> Result<Self, Error>where D: TryInto<Endpoint>, D::Error: Into<StdError>,

impl<T> ClusterServiceClient<T>where T: GrpcService<Body>, T::Error: Into<StdError>, T::ResponseBody: Body<Data = Bytes> + Send + 'static, <T::ResponseBody as Body>::Error: Into<StdError> + Send,

pub fn new(inner: T) -> Self

pub fn with_origin(inner: T, origin: Uri) -> Self

pub fn send_compressed(self, encoding: CompressionEncoding) -> Self

pub fn accept_compressed(self, encoding: CompressionEncoding) -> Self

pub fn max_decoding_message_size(self, limit: usize) -> Self

pub fn max_encoding_message_size(self, limit: usize) -> Self

pub async fn get_cluster_state( &mut self, request: impl IntoRequest<GetClusterStateRequest>, ) -> Result<Response<GetClusterStateResponse>, Status>

pub async fn update_cluster_state( &mut self, request: impl IntoRequest<UpdateClusterStateRequest>, ) -> Result<Response<UpdateClusterStateResponse>, Status>

pub async fn remote_insert_vector( &mut self, request: impl IntoRequest<RemoteInsertVectorRequest>, ) -> Result<Response<RemoteInsertVectorResponse>, Status>

pub async fn remote_update_vector( &mut self, request: impl IntoRequest<RemoteUpdateVectorRequest>, ) -> Result<Response<RemoteUpdateVectorResponse>, Status>

pub async fn remote_delete_vector( &mut self, request: impl IntoRequest<RemoteDeleteVectorRequest>, ) -> Result<Response<RemoteDeleteVectorResponse>, Status>

pub async fn remote_search_vectors( &mut self, request: impl IntoRequest<RemoteSearchVectorsRequest>, ) -> Result<Response<RemoteSearchVectorsResponse>, Status>

pub async fn remote_hybrid_search( &mut self, request: impl IntoRequest<RemoteHybridSearchRequest>, ) -> Result<Response<RemoteHybridSearchResponse>, Status>

pub async fn remote_create_collection( &mut self, request: impl IntoRequest<RemoteCreateCollectionRequest>, ) -> Result<Response<RemoteCreateCollectionResponse>, Status>

pub async fn remote_get_collection_info( &mut self, request: impl IntoRequest<RemoteGetCollectionInfoRequest>, ) -> Result<Response<RemoteGetCollectionInfoResponse>, Status>

pub async fn remote_delete_collection( &mut self, request: impl IntoRequest<RemoteDeleteCollectionRequest>, ) -> Result<Response<RemoteDeleteCollectionResponse>, Status>

pub async fn health_check( &mut self, request: impl IntoRequest<HealthCheckRequest>, ) -> Result<Response<HealthCheckResponse>, Status>

pub async fn check_quota( &mut self, request: impl IntoRequest<CheckQuotaRequest>, ) -> Result<Response<CheckQuotaResponse>, Status>

pub async fn get_shard_vectors( &mut self, request: impl IntoRequest<GetShardVectorsRequest>, ) -> Result<Response<GetShardVectorsResponse>, Status>

pub async fn raft_vote( &mut self, request: impl IntoRequest<RaftVoteRequest>, ) -> Result<Response<RaftVoteResponse>, Status>

pub async fn raft_append_entries( &mut self, request: impl IntoRequest<RaftAppendEntriesRequest>, ) -> Result<Response<RaftAppendEntriesResponse>, Status>

pub async fn raft_snapshot( &mut self, request: impl IntoRequest<RaftSnapshotRequest>, ) -> Result<Response<RaftSnapshotResponse>, Status>

Trait Implementations§

impl<T: Clone> Clone for ClusterServiceClient<T>

fn clone(&self) -> ClusterServiceClient<T>

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

impl<T: Debug> Debug for ClusterServiceClient<T>

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

Auto Trait Implementations§

impl<T> !Freeze for ClusterServiceClient<T>

impl<T> RefUnwindSafe for ClusterServiceClient<T>where T: RefUnwindSafe,

impl<T> Send for ClusterServiceClient<T>where T: Send,

impl<T> Sync for ClusterServiceClient<T>where T: Sync,

impl<T> Unpin for ClusterServiceClient<T>where T: Unpin,

impl<T> UnsafeUnpin for ClusterServiceClient<T>where T: UnsafeUnpin,

impl<T> UnwindSafe for ClusterServiceClient<T>where T: UnwindSafe,

Blanket Implementations§

impl<T> Any for Twhere T: 'static + ?Sized,

fn type_id(&self) -> TypeId

impl<T> Borrow<T> for Twhere T: ?Sized,

fn borrow(&self) -> &T

impl<T> BorrowMut<T> for Twhere T: ?Sized,

fn borrow_mut(&mut self) -> &mut T

impl<T> CloneToUninit for Twhere T: Clone,

unsafe fn clone_to_uninit(&self, dest: *mut u8)

impl<T> From<T> for T

fn from(t: T) -> T

impl<T> FromRef<T> for Twhere T: Clone,

fn from_ref(input: &T) -> T

impl<T> Instrument for T

fn instrument(self, span: Span) -> Instrumented<Self>

fn in_current_span(self) -> Instrumented<Self>

impl<T, U> Into<U> for Twhere U: From<T>,

fn into(self) -> U

impl<T> IntoRequest<T> for T

fn into_request(self) -> Request<T>

impl<L> LayerExt<L> for L

fn named_layer<S>(&self, service: S) -> Layered<<L as Layer<S>>::Service, S>where L: Layer<S>,

impl<T> ToOwned for Twhere T: Clone,

type Owned = T

fn to_owned(&self) -> T

fn clone_into(&self, target: &mut T)

impl<T, U> TryFrom<U> for Twhere U: Into<T>,

type Error = Infallible

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

impl<T, U> TryInto<U> for Twhere U: TryFrom<T>,

type Error = <U as TryFrom<T>>::Error

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

impl<T> WithSubscriber for T

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>where S: Into<Dispatch>,

fn with_current_subscriber(self) -> WithDispatch<Self>

Struct ClusterServiceClient

pub async fn connect<D>(dst: D) -> Result<Self, Error>
where D: TryInto<Endpoint>, D::Error: Into<StdError>,

impl<T> ClusterServiceClient<T>
where T: GrpcService<Body>, T::Error: Into<StdError>, T::ResponseBody: Body<Data = Bytes> + Send + 'static, <T::ResponseBody as Body>::Error: Into<StdError> + Send,

impl<T> RefUnwindSafe for ClusterServiceClient<T>
where T: RefUnwindSafe,

impl<T> Send for ClusterServiceClient<T>
where T: Send,

impl<T> Sync for ClusterServiceClient<T>
where T: Sync,

impl<T> Unpin for ClusterServiceClient<T>
where T: Unpin,

impl<T> UnsafeUnpin for ClusterServiceClient<T>
where T: UnsafeUnpin,

impl<T> UnwindSafe for ClusterServiceClient<T>
where T: UnwindSafe,

impl<T> Any for T
where T: 'static + ?Sized,

impl<T> Borrow<T> for T
where T: ?Sized,

impl<T> BorrowMut<T> for T
where T: ?Sized,

impl<T> CloneToUninit for T
where T: Clone,

impl<T> FromRef<T> for T
where T: Clone,

impl<T, U> Into<U> for T
where U: From<T>,

fn named_layer<S>(&self, service: S) -> Layered<<L as Layer<S>>::Service, S>
where L: Layer<S>,

impl<T> ToOwned for T
where T: Clone,

impl<T, U> TryFrom<U> for T
where U: Into<T>,

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,