Struct MilvusServiceClient

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

Implementations

impl MilvusServiceClient<Channel>

pub async fn connect<D>(dst: D) -> Result<Self, Error>

where D: TryInto<Endpoint>, D::Error: Into<StdError>,

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

impl<T> MilvusServiceClient<T>

where T: GrpcService<BoxBody>, 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 with_interceptor<F>( inner: T, interceptor: F, ) -> MilvusServiceClient<InterceptedService<T, F>>

where F: Interceptor, T::ResponseBody: Default, T: Service<Request<BoxBody>, Response = Response<<T as GrpcService<BoxBody>>::ResponseBody>>, <T as Service<Request<BoxBody>>>::Error: Into<StdError> + Send + Sync,

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

Compress requests with the given encoding.

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

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

Enable decompressing responses.

pub async fn create_collection( &mut self, request: impl IntoRequest<CreateCollectionRequest>, ) -> Result<Response<Status>, Status>

pub async fn drop_collection( &mut self, request: impl IntoRequest<DropCollectionRequest>, ) -> Result<Response<Status>, Status>

pub async fn has_collection( &mut self, request: impl IntoRequest<HasCollectionRequest>, ) -> Result<Response<BoolResponse>, Status>

pub async fn load_collection( &mut self, request: impl IntoRequest<LoadCollectionRequest>, ) -> Result<Response<Status>, Status>

pub async fn release_collection( &mut self, request: impl IntoRequest<ReleaseCollectionRequest>, ) -> Result<Response<Status>, Status>

pub async fn describe_collection( &mut self, request: impl IntoRequest<DescribeCollectionRequest>, ) -> Result<Response<DescribeCollectionResponse>, Status>

pub async fn get_collection_statistics( &mut self, request: impl IntoRequest<GetCollectionStatisticsRequest>, ) -> Result<Response<GetCollectionStatisticsResponse>, Status>

pub async fn show_collections( &mut self, request: impl IntoRequest<ShowCollectionsRequest>, ) -> Result<Response<ShowCollectionsResponse>, Status>

pub async fn alter_collection( &mut self, request: impl IntoRequest<AlterCollectionRequest>, ) -> Result<Response<Status>, Status>

pub async fn create_partition( &mut self, request: impl IntoRequest<CreatePartitionRequest>, ) -> Result<Response<Status>, Status>

pub async fn drop_partition( &mut self, request: impl IntoRequest<DropPartitionRequest>, ) -> Result<Response<Status>, Status>

pub async fn has_partition( &mut self, request: impl IntoRequest<HasPartitionRequest>, ) -> Result<Response<BoolResponse>, Status>

pub async fn load_partitions( &mut self, request: impl IntoRequest<LoadPartitionsRequest>, ) -> Result<Response<Status>, Status>

pub async fn release_partitions( &mut self, request: impl IntoRequest<ReleasePartitionsRequest>, ) -> Result<Response<Status>, Status>

pub async fn get_partition_statistics( &mut self, request: impl IntoRequest<GetPartitionStatisticsRequest>, ) -> Result<Response<GetPartitionStatisticsResponse>, Status>

pub async fn show_partitions( &mut self, request: impl IntoRequest<ShowPartitionsRequest>, ) -> Result<Response<ShowPartitionsResponse>, Status>

pub async fn get_loading_progress( &mut self, request: impl IntoRequest<GetLoadingProgressRequest>, ) -> Result<Response<GetLoadingProgressResponse>, Status>

pub async fn create_alias( &mut self, request: impl IntoRequest<CreateAliasRequest>, ) -> Result<Response<Status>, Status>

pub async fn drop_alias( &mut self, request: impl IntoRequest<DropAliasRequest>, ) -> Result<Response<Status>, Status>

pub async fn alter_alias( &mut self, request: impl IntoRequest<AlterAliasRequest>, ) -> Result<Response<Status>, Status>

pub async fn create_index( &mut self, request: impl IntoRequest<CreateIndexRequest>, ) -> Result<Response<Status>, Status>

pub async fn describe_index( &mut self, request: impl IntoRequest<DescribeIndexRequest>, ) -> Result<Response<DescribeIndexResponse>, Status>

pub async fn get_index_state( &mut self, request: impl IntoRequest<GetIndexStateRequest>, ) -> Result<Response<GetIndexStateResponse>, Status>

Deprecated: use DescribeIndex instead

pub async fn get_index_build_progress( &mut self, request: impl IntoRequest<GetIndexBuildProgressRequest>, ) -> Result<Response<GetIndexBuildProgressResponse>, Status>

Deprecated: use DescribeIndex instead

pub async fn drop_index( &mut self, request: impl IntoRequest<DropIndexRequest>, ) -> Result<Response<Status>, Status>

pub async fn insert( &mut self, request: impl IntoRequest<InsertRequest>, ) -> Result<Response<MutationResult>, Status>

pub async fn delete( &mut self, request: impl IntoRequest<DeleteRequest>, ) -> Result<Response<MutationResult>, Status>

pub async fn search( &mut self, request: impl IntoRequest<SearchRequest>, ) -> Result<Response<SearchResults>, Status>

pub async fn flush( &mut self, request: impl IntoRequest<FlushRequest>, ) -> Result<Response<FlushResponse>, Status>

pub async fn query( &mut self, request: impl IntoRequest<QueryRequest>, ) -> Result<Response<QueryResults>, Status>

pub async fn calc_distance( &mut self, request: impl IntoRequest<CalcDistanceRequest>, ) -> Result<Response<CalcDistanceResults>, Status>

pub async fn get_flush_state( &mut self, request: impl IntoRequest<GetFlushStateRequest>, ) -> Result<Response<GetFlushStateResponse>, Status>

pub async fn get_persistent_segment_info( &mut self, request: impl IntoRequest<GetPersistentSegmentInfoRequest>, ) -> Result<Response<GetPersistentSegmentInfoResponse>, Status>

pub async fn get_query_segment_info( &mut self, request: impl IntoRequest<GetQuerySegmentInfoRequest>, ) -> Result<Response<GetQuerySegmentInfoResponse>, Status>

pub async fn get_replicas( &mut self, request: impl IntoRequest<GetReplicasRequest>, ) -> Result<Response<GetReplicasResponse>, Status>

pub async fn dummy( &mut self, request: impl IntoRequest<DummyRequest>, ) -> Result<Response<DummyResponse>, Status>

pub async fn register_link( &mut self, request: impl IntoRequest<RegisterLinkRequest>, ) -> Result<Response<RegisterLinkResponse>, Status>

TODO: remove

pub async fn get_metrics( &mut self, request: impl IntoRequest<GetMetricsRequest>, ) -> Result<Response<GetMetricsResponse>, Status>

https://wiki.lfaidata.foundation/display/MIL/MEP+8+–+Add+metrics+for+proxy

pub async fn get_component_states( &mut self, request: impl IntoRequest<GetComponentStatesRequest>, ) -> Result<Response<ComponentStates>, Status>

pub async fn load_balance( &mut self, request: impl IntoRequest<LoadBalanceRequest>, ) -> Result<Response<Status>, Status>

pub async fn get_compaction_state( &mut self, request: impl IntoRequest<GetCompactionStateRequest>, ) -> Result<Response<GetCompactionStateResponse>, Status>

pub async fn manual_compaction( &mut self, request: impl IntoRequest<ManualCompactionRequest>, ) -> Result<Response<ManualCompactionResponse>, Status>

pub async fn get_compaction_state_with_plans( &mut self, request: impl IntoRequest<GetCompactionPlansRequest>, ) -> Result<Response<GetCompactionPlansResponse>, Status>

pub async fn import( &mut self, request: impl IntoRequest<ImportRequest>, ) -> Result<Response<ImportResponse>, Status>

https://wiki.lfaidata.foundation/display/MIL/MEP+24+–+Support+bulk+load

pub async fn get_import_state( &mut self, request: impl IntoRequest<GetImportStateRequest>, ) -> Result<Response<GetImportStateResponse>, Status>

pub async fn list_import_tasks( &mut self, request: impl IntoRequest<ListImportTasksRequest>, ) -> Result<Response<ListImportTasksResponse>, Status>

pub async fn create_credential( &mut self, request: impl IntoRequest<CreateCredentialRequest>, ) -> Result<Response<Status>, Status>

https://wiki.lfaidata.foundation/display/MIL/MEP+27+–+Support+Basic+Authentication

pub async fn update_credential( &mut self, request: impl IntoRequest<UpdateCredentialRequest>, ) -> Result<Response<Status>, Status>

pub async fn delete_credential( &mut self, request: impl IntoRequest<DeleteCredentialRequest>, ) -> Result<Response<Status>, Status>

pub async fn list_cred_users( &mut self, request: impl IntoRequest<ListCredUsersRequest>, ) -> Result<Response<ListCredUsersResponse>, Status>

pub async fn create_role( &mut self, request: impl IntoRequest<CreateRoleRequest>, ) -> Result<Response<Status>, Status>

https://wiki.lfaidata.foundation/display/MIL/MEP+29+–+Support+Role-Based+Access+Control

pub async fn drop_role( &mut self, request: impl IntoRequest<DropRoleRequest>, ) -> Result<Response<Status>, Status>

pub async fn operate_user_role( &mut self, request: impl IntoRequest<OperateUserRoleRequest>, ) -> Result<Response<Status>, Status>

pub async fn select_role( &mut self, request: impl IntoRequest<SelectRoleRequest>, ) -> Result<Response<SelectRoleResponse>, Status>

pub async fn select_user( &mut self, request: impl IntoRequest<SelectUserRequest>, ) -> Result<Response<SelectUserResponse>, Status>

pub async fn operate_privilege( &mut self, request: impl IntoRequest<OperatePrivilegeRequest>, ) -> Result<Response<Status>, Status>

pub async fn select_grant( &mut self, request: impl IntoRequest<SelectGrantRequest>, ) -> Result<Response<SelectGrantResponse>, Status>

pub async fn get_version( &mut self, request: impl IntoRequest<GetVersionRequest>, ) -> Result<Response<GetVersionResponse>, Status>

pub async fn check_health( &mut self, request: impl IntoRequest<CheckHealthRequest>, ) -> Result<Response<CheckHealthResponse>, Status>

Trait Implementations

impl<T: Clone> Clone for MilvusServiceClient<T>

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

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<T: Debug> Debug for MilvusServiceClient<T>

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

Formats the value using the given formatter.