Package io.milvus.grpc

Class MilvusServiceGrpc.MilvusServiceFutureStub

java.lang.Object

io.grpc.stub.AbstractStub<S>

io.grpc.stub.AbstractFutureStub<MilvusServiceGrpc.MilvusServiceFutureStub>

io.milvus.grpc.MilvusServiceGrpc.MilvusServiceFutureStub

Enclosing class:

MilvusServiceGrpc

public static final class MilvusServiceGrpc.MilvusServiceFutureStub
extends io.grpc.stub.AbstractFutureStub<MilvusServiceGrpc.MilvusServiceFutureStub>

A stub to allow clients to do ListenableFuture-style rpc calls to service MilvusService.

Nested Class Summary

Nested classes/interfaces inherited from class io.grpc.stub.AbstractStub

io.grpc.stub.AbstractStub.StubFactory<T extends io.grpc.stub.AbstractStub<T>>

Method Summary

Modifier and Type	Method	Description
com.google.common.util.concurrent.ListenableFuture<Status>	addCollectionField(AddCollectionFieldRequest request)
com.google.common.util.concurrent.ListenableFuture<Status>	addCollectionFunction(AddCollectionFunctionRequest request)
com.google.common.util.concurrent.ListenableFuture<Status>	addFileResource(AddFileResourceRequest request)
com.google.common.util.concurrent.ListenableFuture<Status>	addUserTags(AddUserTagsRequest request)	Row Level Security (RLS) APIs
com.google.common.util.concurrent.ListenableFuture<AllocTimestampResponse>	allocTimestamp(AllocTimestampRequest request)
com.google.common.util.concurrent.ListenableFuture<Status>	alterAlias(AlterAliasRequest request)
com.google.common.util.concurrent.ListenableFuture<Status>	alterCollection(AlterCollectionRequest request)
com.google.common.util.concurrent.ListenableFuture<Status>	alterCollectionField(AlterCollectionFieldRequest request)
com.google.common.util.concurrent.ListenableFuture<Status>	alterCollectionFunction(AlterCollectionFunctionRequest request)
com.google.common.util.concurrent.ListenableFuture<AlterCollectionSchemaResponse>	alterCollectionSchema(AlterCollectionSchemaRequest request)
com.google.common.util.concurrent.ListenableFuture<Status>	alterDatabase(AlterDatabaseRequest request)
com.google.common.util.concurrent.ListenableFuture<Status>	alterIndex(AlterIndexRequest request)
com.google.common.util.concurrent.ListenableFuture<BackupRBACMetaResponse>	backupRBAC(BackupRBACMetaRequest request)
com.google.common.util.concurrent.ListenableFuture<BatchDescribeCollectionResponse>	batchDescribeCollection(BatchDescribeCollectionRequest request)
com.google.common.util.concurrent.ListenableFuture<Status>	batchUpdateManifest(BatchUpdateManifestRequest request)
protected MilvusServiceGrpc.MilvusServiceFutureStub	build(io.grpc.Channel channel, io.grpc.CallOptions callOptions)
com.google.common.util.concurrent.ListenableFuture<CalcDistanceResults>	calcDistance(CalcDistanceRequest request)
com.google.common.util.concurrent.ListenableFuture<CheckHealthResponse>	checkHealth(CheckHealthRequest request)
com.google.common.util.concurrent.ListenableFuture<ComputePhraseMatchSlopResponse>	computePhraseMatchSlop(ComputePhraseMatchSlopRequest request)
com.google.common.util.concurrent.ListenableFuture<ConnectResponse>	connect(ConnectRequest request)
com.google.common.util.concurrent.ListenableFuture<Status>	createAlias(CreateAliasRequest request)
com.google.common.util.concurrent.ListenableFuture<Status>	createCollection(CreateCollectionRequest request)
com.google.common.util.concurrent.ListenableFuture<Status>	createCredential(CreateCredentialRequest request)	https://wiki.lfaidata.foundation/display/MIL/MEP+27+--+Support+Basic+Authentication
com.google.common.util.concurrent.ListenableFuture<Status>	createDatabase(CreateDatabaseRequest request)
com.google.common.util.concurrent.ListenableFuture<Status>	createIndex(CreateIndexRequest request)
com.google.common.util.concurrent.ListenableFuture<Status>	createPartition(CreatePartitionRequest request)
com.google.common.util.concurrent.ListenableFuture<Status>	createPrivilegeGroup(CreatePrivilegeGroupRequest request)
com.google.common.util.concurrent.ListenableFuture<Status>	createResourceGroup(CreateResourceGroupRequest request)
com.google.common.util.concurrent.ListenableFuture<Status>	createRole(CreateRoleRequest request)	https://wiki.lfaidata.foundation/display/MIL/MEP+29+--+Support+Role-Based+Access+Control
com.google.common.util.concurrent.ListenableFuture<Status>	createRowPolicy(CreateRowPolicyRequest request)
com.google.common.util.concurrent.ListenableFuture<Status>	createSnapshot(CreateSnapshotRequest request)	snapshot related
com.google.common.util.concurrent.ListenableFuture<MutationResult>	delete(DeleteRequest request)
com.google.common.util.concurrent.ListenableFuture<Status>	deleteCredential(DeleteCredentialRequest request)
com.google.common.util.concurrent.ListenableFuture<Status>	deleteUserTags(DeleteUserTagsRequest request)
com.google.common.util.concurrent.ListenableFuture<DescribeAliasResponse>	describeAlias(DescribeAliasRequest request)
com.google.common.util.concurrent.ListenableFuture<DescribeCollectionResponse>	describeCollection(DescribeCollectionRequest request)
com.google.common.util.concurrent.ListenableFuture<DescribeDatabaseResponse>	describeDatabase(DescribeDatabaseRequest request)
com.google.common.util.concurrent.ListenableFuture<DescribeIndexResponse>	describeIndex(DescribeIndexRequest request)
com.google.common.util.concurrent.ListenableFuture<DescribeResourceGroupResponse>	describeResourceGroup(DescribeResourceGroupRequest request)
com.google.common.util.concurrent.ListenableFuture<Feder.DescribeSegmentIndexDataResponse>	describeSegmentIndexData(Feder.DescribeSegmentIndexDataRequest request)
com.google.common.util.concurrent.ListenableFuture<DescribeSnapshotResponse>	describeSnapshot(DescribeSnapshotRequest request)
com.google.common.util.concurrent.ListenableFuture<Status>	dropAlias(DropAliasRequest request)
com.google.common.util.concurrent.ListenableFuture<Status>	dropCollection(DropCollectionRequest request)
com.google.common.util.concurrent.ListenableFuture<Status>	dropCollectionFunction(DropCollectionFunctionRequest request)
com.google.common.util.concurrent.ListenableFuture<Status>	dropDatabase(DropDatabaseRequest request)
com.google.common.util.concurrent.ListenableFuture<Status>	dropIndex(DropIndexRequest request)
com.google.common.util.concurrent.ListenableFuture<Status>	dropPartition(DropPartitionRequest request)
com.google.common.util.concurrent.ListenableFuture<Status>	dropPrivilegeGroup(DropPrivilegeGroupRequest request)
com.google.common.util.concurrent.ListenableFuture<Status>	dropResourceGroup(DropResourceGroupRequest request)
com.google.common.util.concurrent.ListenableFuture<Status>	dropRole(DropRoleRequest request)
com.google.common.util.concurrent.ListenableFuture<Status>	dropRowPolicy(DropRowPolicyRequest request)
com.google.common.util.concurrent.ListenableFuture<Status>	dropSnapshot(DropSnapshotRequest request)
com.google.common.util.concurrent.ListenableFuture<DummyResponse>	dummy(DummyRequest request)
com.google.common.util.concurrent.ListenableFuture<FlushResponse>	flush(FlushRequest request)
com.google.common.util.concurrent.ListenableFuture<FlushAllResponse>	flushAll(FlushAllRequest request)
com.google.common.util.concurrent.ListenableFuture<GetCollectionStatisticsResponse>	getCollectionStatistics(GetCollectionStatisticsRequest request)
com.google.common.util.concurrent.ListenableFuture<GetCompactionStateResponse>	getCompactionState(GetCompactionStateRequest request)
com.google.common.util.concurrent.ListenableFuture<GetCompactionPlansResponse>	getCompactionStateWithPlans(GetCompactionPlansRequest request)
com.google.common.util.concurrent.ListenableFuture<ComponentStates>	getComponentStates(GetComponentStatesRequest request)
com.google.common.util.concurrent.ListenableFuture<GetFlushAllStateResponse>	getFlushAllState(GetFlushAllStateRequest request)
com.google.common.util.concurrent.ListenableFuture<GetFlushStateResponse>	getFlushState(GetFlushStateRequest request)
com.google.common.util.concurrent.ListenableFuture<GetImportStateResponse>	getImportState(GetImportStateRequest request)
com.google.common.util.concurrent.ListenableFuture<GetIndexBuildProgressResponse>	getIndexBuildProgress(GetIndexBuildProgressRequest request)	Deprecated.
com.google.common.util.concurrent.ListenableFuture<GetIndexStateResponse>	getIndexState(GetIndexStateRequest request)	Deprecated.
com.google.common.util.concurrent.ListenableFuture<GetIndexStatisticsResponse>	getIndexStatistics(GetIndexStatisticsRequest request)
com.google.common.util.concurrent.ListenableFuture<GetLoadingProgressResponse>	getLoadingProgress(GetLoadingProgressRequest request)
com.google.common.util.concurrent.ListenableFuture<GetLoadStateResponse>	getLoadState(GetLoadStateRequest request)
com.google.common.util.concurrent.ListenableFuture<GetMetricsResponse>	getMetrics(GetMetricsRequest request)	https://wiki.lfaidata.foundation/display/MIL/MEP+8+--+Add+metrics+for+proxy
com.google.common.util.concurrent.ListenableFuture<GetPartitionStatisticsResponse>	getPartitionStatistics(GetPartitionStatisticsRequest request)
com.google.common.util.concurrent.ListenableFuture<GetPersistentSegmentInfoResponse>	getPersistentSegmentInfo(GetPersistentSegmentInfoRequest request)
com.google.common.util.concurrent.ListenableFuture<GetQuerySegmentInfoResponse>	getQuerySegmentInfo(GetQuerySegmentInfoRequest request)
com.google.common.util.concurrent.ListenableFuture<GetRefreshExternalCollectionProgressResponse>	getRefreshExternalCollectionProgress(GetRefreshExternalCollectionProgressRequest request)
com.google.common.util.concurrent.ListenableFuture<GetReplicasResponse>	getReplicas(GetReplicasRequest request)
com.google.common.util.concurrent.ListenableFuture<GetReplicateConfigurationResponse>	getReplicateConfiguration(GetReplicateConfigurationRequest request)	GetReplicateConfiguration retrieves the current cross-cluster replication topology.
com.google.common.util.concurrent.ListenableFuture<GetReplicateInfoResponse>	getReplicateInfo(GetReplicateInfoRequest request)	GetReplicateInfo retrieves replication-related metadata of specified channel from a target Milvus cluster.
com.google.common.util.concurrent.ListenableFuture<GetRestoreSnapshotStateResponse>	getRestoreSnapshotState(GetRestoreSnapshotStateRequest request)
com.google.common.util.concurrent.ListenableFuture<GetUserTagsResponse>	getUserTags(GetUserTagsRequest request)
com.google.common.util.concurrent.ListenableFuture<GetVersionResponse>	getVersion(GetVersionRequest request)
com.google.common.util.concurrent.ListenableFuture<BoolResponse>	hasCollection(HasCollectionRequest request)
com.google.common.util.concurrent.ListenableFuture<BoolResponse>	hasPartition(HasPartitionRequest request)
com.google.common.util.concurrent.ListenableFuture<SearchResults>	hybridSearch(HybridSearchRequest request)
com.google.common.util.concurrent.ListenableFuture<ImportResponse>	import_(ImportRequest request)	https://wiki.lfaidata.foundation/display/MIL/MEP+24+--+Support+bulk+load
com.google.common.util.concurrent.ListenableFuture<MutationResult>	insert(InsertRequest request)
com.google.common.util.concurrent.ListenableFuture<ListAliasesResponse>	listAliases(ListAliasesRequest request)
com.google.common.util.concurrent.ListenableFuture<ListCredUsersResponse>	listCredUsers(ListCredUsersRequest request)
com.google.common.util.concurrent.ListenableFuture<ListDatabasesResponse>	listDatabases(ListDatabasesRequest request)
com.google.common.util.concurrent.ListenableFuture<ListFileResourcesResponse>	listFileResources(ListFileResourcesRequest request)
com.google.common.util.concurrent.ListenableFuture<ListImportTasksResponse>	listImportTasks(ListImportTasksRequest request)
com.google.common.util.concurrent.ListenableFuture<Feder.ListIndexedSegmentResponse>	listIndexedSegment(Feder.ListIndexedSegmentRequest request)
com.google.common.util.concurrent.ListenableFuture<ListPrivilegeGroupsResponse>	listPrivilegeGroups(ListPrivilegeGroupsRequest request)
com.google.common.util.concurrent.ListenableFuture<ListRefreshExternalCollectionJobsResponse>	listRefreshExternalCollectionJobs(ListRefreshExternalCollectionJobsRequest request)
com.google.common.util.concurrent.ListenableFuture<ListResourceGroupsResponse>	listResourceGroups(ListResourceGroupsRequest request)
com.google.common.util.concurrent.ListenableFuture<ListRestoreSnapshotJobsResponse>	listRestoreSnapshotJobs(ListRestoreSnapshotJobsRequest request)
com.google.common.util.concurrent.ListenableFuture<ListRowPoliciesResponse>	listRowPolicies(ListRowPoliciesRequest request)
com.google.common.util.concurrent.ListenableFuture<ListSnapshotsResponse>	listSnapshots(ListSnapshotsRequest request)
com.google.common.util.concurrent.ListenableFuture<ListUsersWithTagResponse>	listUsersWithTag(ListUsersWithTagRequest request)
com.google.common.util.concurrent.ListenableFuture<Status>	loadBalance(LoadBalanceRequest request)
com.google.common.util.concurrent.ListenableFuture<Status>	loadCollection(LoadCollectionRequest request)
com.google.common.util.concurrent.ListenableFuture<Status>	loadPartitions(LoadPartitionsRequest request)
com.google.common.util.concurrent.ListenableFuture<ManualCompactionResponse>	manualCompaction(ManualCompactionRequest request)
com.google.common.util.concurrent.ListenableFuture<Status>	operatePrivilege(OperatePrivilegeRequest request)
com.google.common.util.concurrent.ListenableFuture<Status>	operatePrivilegeGroup(OperatePrivilegeGroupRequest request)
com.google.common.util.concurrent.ListenableFuture<Status>	operatePrivilegeV2(OperatePrivilegeV2Request request)
com.google.common.util.concurrent.ListenableFuture<Status>	operateUserRole(OperateUserRoleRequest request)
com.google.common.util.concurrent.ListenableFuture<QueryResults>	query(QueryRequest request)
com.google.common.util.concurrent.ListenableFuture<RefreshExternalCollectionResponse>	refreshExternalCollection(RefreshExternalCollectionRequest request)	External Collection APIs
com.google.common.util.concurrent.ListenableFuture<RegisterLinkResponse>	registerLink(RegisterLinkRequest request)	TODO: remove
com.google.common.util.concurrent.ListenableFuture<Status>	releaseCollection(ReleaseCollectionRequest request)
com.google.common.util.concurrent.ListenableFuture<Status>	releasePartitions(ReleasePartitionsRequest request)
com.google.common.util.concurrent.ListenableFuture<Status>	removeFileResource(RemoveFileResourceRequest request)
com.google.common.util.concurrent.ListenableFuture<Status>	renameCollection(RenameCollectionRequest request)
com.google.common.util.concurrent.ListenableFuture<ReplicateMessageResponse>	replicateMessage(ReplicateMessageRequest request)	Deprecated.
com.google.common.util.concurrent.ListenableFuture<Status>	restoreRBAC(RestoreRBACMetaRequest request)
com.google.common.util.concurrent.ListenableFuture<RestoreSnapshotResponse>	restoreSnapshot(RestoreSnapshotRequest request)
com.google.common.util.concurrent.ListenableFuture<RunAnalyzerResponse>	runAnalyzer(RunAnalyzerRequest request)
com.google.common.util.concurrent.ListenableFuture<SearchResults>	search(SearchRequest request)
com.google.common.util.concurrent.ListenableFuture<SelectGrantResponse>	selectGrant(SelectGrantRequest request)
com.google.common.util.concurrent.ListenableFuture<SelectRoleResponse>	selectRole(SelectRoleRequest request)
com.google.common.util.concurrent.ListenableFuture<SelectUserResponse>	selectUser(SelectUserRequest request)
com.google.common.util.concurrent.ListenableFuture<ShowCollectionsResponse>	showCollections(ShowCollectionsRequest request)
com.google.common.util.concurrent.ListenableFuture<ShowPartitionsResponse>	showPartitions(ShowPartitionsRequest request)
com.google.common.util.concurrent.ListenableFuture<Status>	transferNode(TransferNodeRequest request)
com.google.common.util.concurrent.ListenableFuture<Status>	transferReplica(TransferReplicaRequest request)
com.google.common.util.concurrent.ListenableFuture<TruncateCollectionResponse>	truncateCollection(TruncateCollectionRequest request)
com.google.common.util.concurrent.ListenableFuture<Status>	updateCredential(UpdateCredentialRequest request)
com.google.common.util.concurrent.ListenableFuture<Status>	updateReplicateConfiguration(UpdateReplicateConfigurationRequest request)	CDC v2 APIs UpdateReplicateConfiguration applies a full replacement of the current replication configuration across Milvus clusters.
com.google.common.util.concurrent.ListenableFuture<Status>	updateResourceGroups(UpdateResourceGroupsRequest request)
com.google.common.util.concurrent.ListenableFuture<MutationResult>	upsert(UpsertRequest request)

Methods inherited from class io.grpc.stub.AbstractFutureStub

newStub, newStub

Methods inherited from class io.grpc.stub.AbstractStub

getCallOptions, getChannel, withCallCredentials, withChannel, withCompression, withDeadline, withDeadlineAfter, withExecutor, withInterceptors, withMaxInboundMessageSize, withMaxOutboundMessageSize, withOption, withWaitForReady

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

build

protected MilvusServiceGrpc.MilvusServiceFutureStub build(io.grpc.Channel channel,
                                                          io.grpc.CallOptions callOptions)

Specified by:

build in class io.grpc.stub.AbstractStub<MilvusServiceGrpc.MilvusServiceFutureStub>

createCollection

public com.google.common.util.concurrent.ListenableFuture<Status> createCollection(CreateCollectionRequest request)

dropCollection

public com.google.common.util.concurrent.ListenableFuture<Status> dropCollection(DropCollectionRequest request)

hasCollection

public com.google.common.util.concurrent.ListenableFuture<BoolResponse> hasCollection(HasCollectionRequest request)

loadCollection

public com.google.common.util.concurrent.ListenableFuture<Status> loadCollection(LoadCollectionRequest request)

releaseCollection

public com.google.common.util.concurrent.ListenableFuture<Status> releaseCollection(ReleaseCollectionRequest request)

describeCollection

public com.google.common.util.concurrent.ListenableFuture<DescribeCollectionResponse> describeCollection(DescribeCollectionRequest request)

batchDescribeCollection

public com.google.common.util.concurrent.ListenableFuture<BatchDescribeCollectionResponse> batchDescribeCollection(BatchDescribeCollectionRequest request)

getCollectionStatistics

public com.google.common.util.concurrent.ListenableFuture<GetCollectionStatisticsResponse> getCollectionStatistics(GetCollectionStatisticsRequest request)

showCollections

public com.google.common.util.concurrent.ListenableFuture<ShowCollectionsResponse> showCollections(ShowCollectionsRequest request)

alterCollection

public com.google.common.util.concurrent.ListenableFuture<Status> alterCollection(AlterCollectionRequest request)

alterCollectionField

public com.google.common.util.concurrent.ListenableFuture<Status> alterCollectionField(AlterCollectionFieldRequest request)

addCollectionFunction

public com.google.common.util.concurrent.ListenableFuture<Status> addCollectionFunction(AddCollectionFunctionRequest request)

alterCollectionFunction

public com.google.common.util.concurrent.ListenableFuture<Status> alterCollectionFunction(AlterCollectionFunctionRequest request)

dropCollectionFunction

public com.google.common.util.concurrent.ListenableFuture<Status> dropCollectionFunction(DropCollectionFunctionRequest request)

truncateCollection

public com.google.common.util.concurrent.ListenableFuture<TruncateCollectionResponse> truncateCollection(TruncateCollectionRequest request)

createPartition

public com.google.common.util.concurrent.ListenableFuture<Status> createPartition(CreatePartitionRequest request)

dropPartition

public com.google.common.util.concurrent.ListenableFuture<Status> dropPartition(DropPartitionRequest request)

hasPartition

public com.google.common.util.concurrent.ListenableFuture<BoolResponse> hasPartition(HasPartitionRequest request)

loadPartitions

public com.google.common.util.concurrent.ListenableFuture<Status> loadPartitions(LoadPartitionsRequest request)

releasePartitions

public com.google.common.util.concurrent.ListenableFuture<Status> releasePartitions(ReleasePartitionsRequest request)

getPartitionStatistics

public com.google.common.util.concurrent.ListenableFuture<GetPartitionStatisticsResponse> getPartitionStatistics(GetPartitionStatisticsRequest request)

showPartitions

public com.google.common.util.concurrent.ListenableFuture<ShowPartitionsResponse> showPartitions(ShowPartitionsRequest request)

getLoadingProgress

public com.google.common.util.concurrent.ListenableFuture<GetLoadingProgressResponse> getLoadingProgress(GetLoadingProgressRequest request)

getLoadState

public com.google.common.util.concurrent.ListenableFuture<GetLoadStateResponse> getLoadState(GetLoadStateRequest request)

createAlias

public com.google.common.util.concurrent.ListenableFuture<Status> createAlias(CreateAliasRequest request)

dropAlias

public com.google.common.util.concurrent.ListenableFuture<Status> dropAlias(DropAliasRequest request)

alterAlias

public com.google.common.util.concurrent.ListenableFuture<Status> alterAlias(AlterAliasRequest request)

describeAlias

public com.google.common.util.concurrent.ListenableFuture<DescribeAliasResponse> describeAlias(DescribeAliasRequest request)

listAliases

public com.google.common.util.concurrent.ListenableFuture<ListAliasesResponse> listAliases(ListAliasesRequest request)

createIndex

public com.google.common.util.concurrent.ListenableFuture<Status> createIndex(CreateIndexRequest request)

alterIndex

public com.google.common.util.concurrent.ListenableFuture<Status> alterIndex(AlterIndexRequest request)

describeIndex

public com.google.common.util.concurrent.ListenableFuture<DescribeIndexResponse> describeIndex(DescribeIndexRequest request)

getIndexStatistics

public com.google.common.util.concurrent.ListenableFuture<GetIndexStatisticsResponse> getIndexStatistics(GetIndexStatisticsRequest request)

getIndexState

@Deprecated
public com.google.common.util.concurrent.ListenableFuture<GetIndexStateResponse> getIndexState(GetIndexStateRequest request)

Deprecated.

 Deprecated: use DescribeIndex instead
 

getIndexBuildProgress

@Deprecated
public com.google.common.util.concurrent.ListenableFuture<GetIndexBuildProgressResponse> getIndexBuildProgress(GetIndexBuildProgressRequest request)

Deprecated.

 Deprecated: use DescribeIndex instead
 

dropIndex

public com.google.common.util.concurrent.ListenableFuture<Status> dropIndex(DropIndexRequest request)

insert

public com.google.common.util.concurrent.ListenableFuture<MutationResult> insert(InsertRequest request)

delete

public com.google.common.util.concurrent.ListenableFuture<MutationResult> delete(DeleteRequest request)

upsert

public com.google.common.util.concurrent.ListenableFuture<MutationResult> upsert(UpsertRequest request)

search

public com.google.common.util.concurrent.ListenableFuture<SearchResults> search(SearchRequest request)

hybridSearch

public com.google.common.util.concurrent.ListenableFuture<SearchResults> hybridSearch(HybridSearchRequest request)

flush

public com.google.common.util.concurrent.ListenableFuture<FlushResponse> flush(FlushRequest request)

query

public com.google.common.util.concurrent.ListenableFuture<QueryResults> query(QueryRequest request)

calcDistance

public com.google.common.util.concurrent.ListenableFuture<CalcDistanceResults> calcDistance(CalcDistanceRequest request)

flushAll

public com.google.common.util.concurrent.ListenableFuture<FlushAllResponse> flushAll(FlushAllRequest request)

addCollectionField

public com.google.common.util.concurrent.ListenableFuture<Status> addCollectionField(AddCollectionFieldRequest request)

getFlushState

public com.google.common.util.concurrent.ListenableFuture<GetFlushStateResponse> getFlushState(GetFlushStateRequest request)

getFlushAllState

public com.google.common.util.concurrent.ListenableFuture<GetFlushAllStateResponse> getFlushAllState(GetFlushAllStateRequest request)

getPersistentSegmentInfo

public com.google.common.util.concurrent.ListenableFuture<GetPersistentSegmentInfoResponse> getPersistentSegmentInfo(GetPersistentSegmentInfoRequest request)

getQuerySegmentInfo

public com.google.common.util.concurrent.ListenableFuture<GetQuerySegmentInfoResponse> getQuerySegmentInfo(GetQuerySegmentInfoRequest request)

getReplicas

public com.google.common.util.concurrent.ListenableFuture<GetReplicasResponse> getReplicas(GetReplicasRequest request)

dummy

public com.google.common.util.concurrent.ListenableFuture<DummyResponse> dummy(DummyRequest request)

registerLink

public com.google.common.util.concurrent.ListenableFuture<RegisterLinkResponse> registerLink(RegisterLinkRequest request)

 TODO: remove
 

getMetrics

public com.google.common.util.concurrent.ListenableFuture<GetMetricsResponse> getMetrics(GetMetricsRequest request)

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

getComponentStates

public com.google.common.util.concurrent.ListenableFuture<ComponentStates> getComponentStates(GetComponentStatesRequest request)

loadBalance

public com.google.common.util.concurrent.ListenableFuture<Status> loadBalance(LoadBalanceRequest request)

getCompactionState

public com.google.common.util.concurrent.ListenableFuture<GetCompactionStateResponse> getCompactionState(GetCompactionStateRequest request)

manualCompaction

public com.google.common.util.concurrent.ListenableFuture<ManualCompactionResponse> manualCompaction(ManualCompactionRequest request)

getCompactionStateWithPlans

public com.google.common.util.concurrent.ListenableFuture<GetCompactionPlansResponse> getCompactionStateWithPlans(GetCompactionPlansRequest request)

import_

public com.google.common.util.concurrent.ListenableFuture<ImportResponse> import_(ImportRequest request)

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

getImportState

public com.google.common.util.concurrent.ListenableFuture<GetImportStateResponse> getImportState(GetImportStateRequest request)

listImportTasks

public com.google.common.util.concurrent.ListenableFuture<ListImportTasksResponse> listImportTasks(ListImportTasksRequest request)

createCredential

public com.google.common.util.concurrent.ListenableFuture<Status> createCredential(CreateCredentialRequest request)

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

updateCredential

public com.google.common.util.concurrent.ListenableFuture<Status> updateCredential(UpdateCredentialRequest request)

deleteCredential

public com.google.common.util.concurrent.ListenableFuture<Status> deleteCredential(DeleteCredentialRequest request)

listCredUsers

public com.google.common.util.concurrent.ListenableFuture<ListCredUsersResponse> listCredUsers(ListCredUsersRequest request)

createRole

public com.google.common.util.concurrent.ListenableFuture<Status> createRole(CreateRoleRequest request)

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

dropRole

public com.google.common.util.concurrent.ListenableFuture<Status> dropRole(DropRoleRequest request)

operateUserRole

public com.google.common.util.concurrent.ListenableFuture<Status> operateUserRole(OperateUserRoleRequest request)

selectRole

public com.google.common.util.concurrent.ListenableFuture<SelectRoleResponse> selectRole(SelectRoleRequest request)

selectUser

public com.google.common.util.concurrent.ListenableFuture<SelectUserResponse> selectUser(SelectUserRequest request)

operatePrivilege

public com.google.common.util.concurrent.ListenableFuture<Status> operatePrivilege(OperatePrivilegeRequest request)

operatePrivilegeV2

public com.google.common.util.concurrent.ListenableFuture<Status> operatePrivilegeV2(OperatePrivilegeV2Request request)

selectGrant

public com.google.common.util.concurrent.ListenableFuture<SelectGrantResponse> selectGrant(SelectGrantRequest request)

getVersion

public com.google.common.util.concurrent.ListenableFuture<GetVersionResponse> getVersion(GetVersionRequest request)

checkHealth

public com.google.common.util.concurrent.ListenableFuture<CheckHealthResponse> checkHealth(CheckHealthRequest request)

createResourceGroup

public com.google.common.util.concurrent.ListenableFuture<Status> createResourceGroup(CreateResourceGroupRequest request)

dropResourceGroup

public com.google.common.util.concurrent.ListenableFuture<Status> dropResourceGroup(DropResourceGroupRequest request)

updateResourceGroups

public com.google.common.util.concurrent.ListenableFuture<Status> updateResourceGroups(UpdateResourceGroupsRequest request)

transferNode

public com.google.common.util.concurrent.ListenableFuture<Status> transferNode(TransferNodeRequest request)

transferReplica

public com.google.common.util.concurrent.ListenableFuture<Status> transferReplica(TransferReplicaRequest request)

listResourceGroups

public com.google.common.util.concurrent.ListenableFuture<ListResourceGroupsResponse> listResourceGroups(ListResourceGroupsRequest request)

describeResourceGroup

public com.google.common.util.concurrent.ListenableFuture<DescribeResourceGroupResponse> describeResourceGroup(DescribeResourceGroupRequest request)

renameCollection

public com.google.common.util.concurrent.ListenableFuture<Status> renameCollection(RenameCollectionRequest request)

listIndexedSegment

public com.google.common.util.concurrent.ListenableFuture<Feder.ListIndexedSegmentResponse> listIndexedSegment(Feder.ListIndexedSegmentRequest request)

describeSegmentIndexData

public com.google.common.util.concurrent.ListenableFuture<Feder.DescribeSegmentIndexDataResponse> describeSegmentIndexData(Feder.DescribeSegmentIndexDataRequest request)

connect

public com.google.common.util.concurrent.ListenableFuture<ConnectResponse> connect(ConnectRequest request)

allocTimestamp

public com.google.common.util.concurrent.ListenableFuture<AllocTimestampResponse> allocTimestamp(AllocTimestampRequest request)

createDatabase

public com.google.common.util.concurrent.ListenableFuture<Status> createDatabase(CreateDatabaseRequest request)

dropDatabase

public com.google.common.util.concurrent.ListenableFuture<Status> dropDatabase(DropDatabaseRequest request)

listDatabases

public com.google.common.util.concurrent.ListenableFuture<ListDatabasesResponse> listDatabases(ListDatabasesRequest request)

alterDatabase

public com.google.common.util.concurrent.ListenableFuture<Status> alterDatabase(AlterDatabaseRequest request)

describeDatabase

public com.google.common.util.concurrent.ListenableFuture<DescribeDatabaseResponse> describeDatabase(DescribeDatabaseRequest request)

replicateMessage

@Deprecated
public com.google.common.util.concurrent.ListenableFuture<ReplicateMessageResponse> replicateMessage(ReplicateMessageRequest request)

Deprecated.

 Deprecated CDC API
 

backupRBAC

public com.google.common.util.concurrent.ListenableFuture<BackupRBACMetaResponse> backupRBAC(BackupRBACMetaRequest request)

restoreRBAC

public com.google.common.util.concurrent.ListenableFuture<Status> restoreRBAC(RestoreRBACMetaRequest request)

createPrivilegeGroup

public com.google.common.util.concurrent.ListenableFuture<Status> createPrivilegeGroup(CreatePrivilegeGroupRequest request)

dropPrivilegeGroup

public com.google.common.util.concurrent.ListenableFuture<Status> dropPrivilegeGroup(DropPrivilegeGroupRequest request)

listPrivilegeGroups

public com.google.common.util.concurrent.ListenableFuture<ListPrivilegeGroupsResponse> listPrivilegeGroups(ListPrivilegeGroupsRequest request)

operatePrivilegeGroup

public com.google.common.util.concurrent.ListenableFuture<Status> operatePrivilegeGroup(OperatePrivilegeGroupRequest request)

runAnalyzer

public com.google.common.util.concurrent.ListenableFuture<RunAnalyzerResponse> runAnalyzer(RunAnalyzerRequest request)

addFileResource

public com.google.common.util.concurrent.ListenableFuture<Status> addFileResource(AddFileResourceRequest request)

removeFileResource

public com.google.common.util.concurrent.ListenableFuture<Status> removeFileResource(RemoveFileResourceRequest request)

listFileResources

public com.google.common.util.concurrent.ListenableFuture<ListFileResourcesResponse> listFileResources(ListFileResourcesRequest request)

addUserTags

public com.google.common.util.concurrent.ListenableFuture<Status> addUserTags(AddUserTagsRequest request)

 Row Level Security (RLS) APIs
 

deleteUserTags

public com.google.common.util.concurrent.ListenableFuture<Status> deleteUserTags(DeleteUserTagsRequest request)

getUserTags

public com.google.common.util.concurrent.ListenableFuture<GetUserTagsResponse> getUserTags(GetUserTagsRequest request)

listUsersWithTag

public com.google.common.util.concurrent.ListenableFuture<ListUsersWithTagResponse> listUsersWithTag(ListUsersWithTagRequest request)

createRowPolicy

public com.google.common.util.concurrent.ListenableFuture<Status> createRowPolicy(CreateRowPolicyRequest request)

dropRowPolicy

public com.google.common.util.concurrent.ListenableFuture<Status> dropRowPolicy(DropRowPolicyRequest request)

listRowPolicies

public com.google.common.util.concurrent.ListenableFuture<ListRowPoliciesResponse> listRowPolicies(ListRowPoliciesRequest request)

updateReplicateConfiguration

public com.google.common.util.concurrent.ListenableFuture<Status> updateReplicateConfiguration(UpdateReplicateConfigurationRequest request)

 CDC v2 APIs
 UpdateReplicateConfiguration applies a full replacement of the current
 replication configuration across Milvus clusters.
 Semantics:
   - The provided ReplicateConfiguration completely replaces any existing
     configuration persisted in the metadata store.
   - Passing an empty ReplicateConfiguration is treated as a "clear"
     operation, effectively removing all replication configuration.
   - The RPC is expected to be idempotent: submitting the same configuration
     multiple times must not cause side effects.
 

getReplicateConfiguration

public com.google.common.util.concurrent.ListenableFuture<GetReplicateConfigurationResponse> getReplicateConfiguration(GetReplicateConfigurationRequest request)

 GetReplicateConfiguration retrieves the current cross-cluster replication topology.
 Sensitive fields (like connection tokens) are redacted in the response.
 

getReplicateInfo

public com.google.common.util.concurrent.ListenableFuture<GetReplicateInfoResponse> getReplicateInfo(GetReplicateInfoRequest request)

 GetReplicateInfo retrieves replication-related metadata of specified channel from a target Milvus cluster.
 

computePhraseMatchSlop

public com.google.common.util.concurrent.ListenableFuture<ComputePhraseMatchSlopResponse> computePhraseMatchSlop(ComputePhraseMatchSlopRequest request)

createSnapshot

public com.google.common.util.concurrent.ListenableFuture<Status> createSnapshot(CreateSnapshotRequest request)

 snapshot related
 

dropSnapshot

public com.google.common.util.concurrent.ListenableFuture<Status> dropSnapshot(DropSnapshotRequest request)

listSnapshots

public com.google.common.util.concurrent.ListenableFuture<ListSnapshotsResponse> listSnapshots(ListSnapshotsRequest request)

describeSnapshot

public com.google.common.util.concurrent.ListenableFuture<DescribeSnapshotResponse> describeSnapshot(DescribeSnapshotRequest request)

restoreSnapshot

public com.google.common.util.concurrent.ListenableFuture<RestoreSnapshotResponse> restoreSnapshot(RestoreSnapshotRequest request)

getRestoreSnapshotState

public com.google.common.util.concurrent.ListenableFuture<GetRestoreSnapshotStateResponse> getRestoreSnapshotState(GetRestoreSnapshotStateRequest request)

listRestoreSnapshotJobs

public com.google.common.util.concurrent.ListenableFuture<ListRestoreSnapshotJobsResponse> listRestoreSnapshotJobs(ListRestoreSnapshotJobsRequest request)

alterCollectionSchema

public com.google.common.util.concurrent.ListenableFuture<AlterCollectionSchemaResponse> alterCollectionSchema(AlterCollectionSchemaRequest request)

batchUpdateManifest

public com.google.common.util.concurrent.ListenableFuture<Status> batchUpdateManifest(BatchUpdateManifestRequest request)

refreshExternalCollection

public com.google.common.util.concurrent.ListenableFuture<RefreshExternalCollectionResponse> refreshExternalCollection(RefreshExternalCollectionRequest request)

 External Collection APIs
 

getRefreshExternalCollectionProgress

public com.google.common.util.concurrent.ListenableFuture<GetRefreshExternalCollectionProgressResponse> getRefreshExternalCollectionProgress(GetRefreshExternalCollectionProgressRequest request)

listRefreshExternalCollectionJobs

public com.google.common.util.concurrent.ListenableFuture<ListRefreshExternalCollectionJobsResponse> listRefreshExternalCollectionJobs(ListRefreshExternalCollectionJobsRequest request)