Package io.milvus.grpc

Interface MilvusServiceGrpc.AsyncService

All Known Implementing Classes:

MilvusServiceGrpc.MilvusServiceImplBase

Enclosing class:

MilvusServiceGrpc

public static interface MilvusServiceGrpc.AsyncService

Method Summary

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

Method Detail

createCollection

default void createCollection(CreateCollectionRequest request,
                              io.grpc.stub.StreamObserver<Status> responseObserver)

dropCollection

default void dropCollection(DropCollectionRequest request,
                            io.grpc.stub.StreamObserver<Status> responseObserver)

hasCollection

default void hasCollection(HasCollectionRequest request,
                           io.grpc.stub.StreamObserver<BoolResponse> responseObserver)

loadCollection

default void loadCollection(LoadCollectionRequest request,
                            io.grpc.stub.StreamObserver<Status> responseObserver)

releaseCollection

default void releaseCollection(ReleaseCollectionRequest request,
                               io.grpc.stub.StreamObserver<Status> responseObserver)

describeCollection

default void describeCollection(DescribeCollectionRequest request,
                                io.grpc.stub.StreamObserver<DescribeCollectionResponse> responseObserver)

batchDescribeCollection

default void batchDescribeCollection(BatchDescribeCollectionRequest request,
                                     io.grpc.stub.StreamObserver<BatchDescribeCollectionResponse> responseObserver)

getCollectionStatistics

default void getCollectionStatistics(GetCollectionStatisticsRequest request,
                                     io.grpc.stub.StreamObserver<GetCollectionStatisticsResponse> responseObserver)

showCollections

default void showCollections(ShowCollectionsRequest request,
                             io.grpc.stub.StreamObserver<ShowCollectionsResponse> responseObserver)

alterCollection

default void alterCollection(AlterCollectionRequest request,
                             io.grpc.stub.StreamObserver<Status> responseObserver)

alterCollectionField

default void alterCollectionField(AlterCollectionFieldRequest request,
                                  io.grpc.stub.StreamObserver<Status> responseObserver)

addCollectionFunction

default void addCollectionFunction(AddCollectionFunctionRequest request,
                                   io.grpc.stub.StreamObserver<Status> responseObserver)

alterCollectionFunction

default void alterCollectionFunction(AlterCollectionFunctionRequest request,
                                     io.grpc.stub.StreamObserver<Status> responseObserver)

dropCollectionFunction

default void dropCollectionFunction(DropCollectionFunctionRequest request,
                                    io.grpc.stub.StreamObserver<Status> responseObserver)

truncateCollection

default void truncateCollection(TruncateCollectionRequest request,
                                io.grpc.stub.StreamObserver<TruncateCollectionResponse> responseObserver)

createPartition

default void createPartition(CreatePartitionRequest request,
                             io.grpc.stub.StreamObserver<Status> responseObserver)

dropPartition

default void dropPartition(DropPartitionRequest request,
                           io.grpc.stub.StreamObserver<Status> responseObserver)

hasPartition

default void hasPartition(HasPartitionRequest request,
                          io.grpc.stub.StreamObserver<BoolResponse> responseObserver)

loadPartitions

default void loadPartitions(LoadPartitionsRequest request,
                            io.grpc.stub.StreamObserver<Status> responseObserver)

releasePartitions

default void releasePartitions(ReleasePartitionsRequest request,
                               io.grpc.stub.StreamObserver<Status> responseObserver)

getPartitionStatistics

default void getPartitionStatistics(GetPartitionStatisticsRequest request,
                                    io.grpc.stub.StreamObserver<GetPartitionStatisticsResponse> responseObserver)

showPartitions

default void showPartitions(ShowPartitionsRequest request,
                            io.grpc.stub.StreamObserver<ShowPartitionsResponse> responseObserver)

getLoadingProgress

default void getLoadingProgress(GetLoadingProgressRequest request,
                                io.grpc.stub.StreamObserver<GetLoadingProgressResponse> responseObserver)

getLoadState

default void getLoadState(GetLoadStateRequest request,
                          io.grpc.stub.StreamObserver<GetLoadStateResponse> responseObserver)

createAlias

default void createAlias(CreateAliasRequest request,
                         io.grpc.stub.StreamObserver<Status> responseObserver)

dropAlias

default void dropAlias(DropAliasRequest request,
                       io.grpc.stub.StreamObserver<Status> responseObserver)

alterAlias

default void alterAlias(AlterAliasRequest request,
                        io.grpc.stub.StreamObserver<Status> responseObserver)

describeAlias

default void describeAlias(DescribeAliasRequest request,
                           io.grpc.stub.StreamObserver<DescribeAliasResponse> responseObserver)

listAliases

default void listAliases(ListAliasesRequest request,
                         io.grpc.stub.StreamObserver<ListAliasesResponse> responseObserver)

createIndex

default void createIndex(CreateIndexRequest request,
                         io.grpc.stub.StreamObserver<Status> responseObserver)

alterIndex

default void alterIndex(AlterIndexRequest request,
                        io.grpc.stub.StreamObserver<Status> responseObserver)

describeIndex

default void describeIndex(DescribeIndexRequest request,
                           io.grpc.stub.StreamObserver<DescribeIndexResponse> responseObserver)

getIndexStatistics

default void getIndexStatistics(GetIndexStatisticsRequest request,
                                io.grpc.stub.StreamObserver<GetIndexStatisticsResponse> responseObserver)

getIndexState

@Deprecated
default void getIndexState(GetIndexStateRequest request,
                           io.grpc.stub.StreamObserver<GetIndexStateResponse> responseObserver)

Deprecated.

 Deprecated: use DescribeIndex instead
 

getIndexBuildProgress

@Deprecated
default void getIndexBuildProgress(GetIndexBuildProgressRequest request,
                                   io.grpc.stub.StreamObserver<GetIndexBuildProgressResponse> responseObserver)

Deprecated.

 Deprecated: use DescribeIndex instead
 

dropIndex

default void dropIndex(DropIndexRequest request,
                       io.grpc.stub.StreamObserver<Status> responseObserver)

insert

default void insert(InsertRequest request,
                    io.grpc.stub.StreamObserver<MutationResult> responseObserver)

delete

default void delete(DeleteRequest request,
                    io.grpc.stub.StreamObserver<MutationResult> responseObserver)

upsert

default void upsert(UpsertRequest request,
                    io.grpc.stub.StreamObserver<MutationResult> responseObserver)

search

default void search(SearchRequest request,
                    io.grpc.stub.StreamObserver<SearchResults> responseObserver)

hybridSearch

default void hybridSearch(HybridSearchRequest request,
                          io.grpc.stub.StreamObserver<SearchResults> responseObserver)

flush

default void flush(FlushRequest request,
                   io.grpc.stub.StreamObserver<FlushResponse> responseObserver)

query

default void query(QueryRequest request,
                   io.grpc.stub.StreamObserver<QueryResults> responseObserver)

calcDistance

default void calcDistance(CalcDistanceRequest request,
                          io.grpc.stub.StreamObserver<CalcDistanceResults> responseObserver)

flushAll

default void flushAll(FlushAllRequest request,
                      io.grpc.stub.StreamObserver<FlushAllResponse> responseObserver)

addCollectionField

default void addCollectionField(AddCollectionFieldRequest request,
                                io.grpc.stub.StreamObserver<Status> responseObserver)

getFlushState

default void getFlushState(GetFlushStateRequest request,
                           io.grpc.stub.StreamObserver<GetFlushStateResponse> responseObserver)

getFlushAllState

default void getFlushAllState(GetFlushAllStateRequest request,
                              io.grpc.stub.StreamObserver<GetFlushAllStateResponse> responseObserver)

getPersistentSegmentInfo

default void getPersistentSegmentInfo(GetPersistentSegmentInfoRequest request,
                                      io.grpc.stub.StreamObserver<GetPersistentSegmentInfoResponse> responseObserver)

getQuerySegmentInfo

default void getQuerySegmentInfo(GetQuerySegmentInfoRequest request,
                                 io.grpc.stub.StreamObserver<GetQuerySegmentInfoResponse> responseObserver)

getReplicas

default void getReplicas(GetReplicasRequest request,
                         io.grpc.stub.StreamObserver<GetReplicasResponse> responseObserver)

dummy

default void dummy(DummyRequest request,
                   io.grpc.stub.StreamObserver<DummyResponse> responseObserver)

registerLink

default void registerLink(RegisterLinkRequest request,
                          io.grpc.stub.StreamObserver<RegisterLinkResponse> responseObserver)

 TODO: remove
 

getMetrics

default void getMetrics(GetMetricsRequest request,
                        io.grpc.stub.StreamObserver<GetMetricsResponse> responseObserver)

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

getComponentStates

default void getComponentStates(GetComponentStatesRequest request,
                                io.grpc.stub.StreamObserver<ComponentStates> responseObserver)

loadBalance

default void loadBalance(LoadBalanceRequest request,
                         io.grpc.stub.StreamObserver<Status> responseObserver)

getCompactionState

default void getCompactionState(GetCompactionStateRequest request,
                                io.grpc.stub.StreamObserver<GetCompactionStateResponse> responseObserver)

manualCompaction

default void manualCompaction(ManualCompactionRequest request,
                              io.grpc.stub.StreamObserver<ManualCompactionResponse> responseObserver)

getCompactionStateWithPlans

default void getCompactionStateWithPlans(GetCompactionPlansRequest request,
                                         io.grpc.stub.StreamObserver<GetCompactionPlansResponse> responseObserver)

import_

default void import_(ImportRequest request,
                     io.grpc.stub.StreamObserver<ImportResponse> responseObserver)

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

getImportState

default void getImportState(GetImportStateRequest request,
                            io.grpc.stub.StreamObserver<GetImportStateResponse> responseObserver)

listImportTasks

default void listImportTasks(ListImportTasksRequest request,
                             io.grpc.stub.StreamObserver<ListImportTasksResponse> responseObserver)

createCredential

default void createCredential(CreateCredentialRequest request,
                              io.grpc.stub.StreamObserver<Status> responseObserver)

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

updateCredential

default void updateCredential(UpdateCredentialRequest request,
                              io.grpc.stub.StreamObserver<Status> responseObserver)

deleteCredential

default void deleteCredential(DeleteCredentialRequest request,
                              io.grpc.stub.StreamObserver<Status> responseObserver)

listCredUsers

default void listCredUsers(ListCredUsersRequest request,
                           io.grpc.stub.StreamObserver<ListCredUsersResponse> responseObserver)

createRole

default void createRole(CreateRoleRequest request,
                        io.grpc.stub.StreamObserver<Status> responseObserver)

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

dropRole

default void dropRole(DropRoleRequest request,
                      io.grpc.stub.StreamObserver<Status> responseObserver)

operateUserRole

default void operateUserRole(OperateUserRoleRequest request,
                             io.grpc.stub.StreamObserver<Status> responseObserver)

selectRole

default void selectRole(SelectRoleRequest request,
                        io.grpc.stub.StreamObserver<SelectRoleResponse> responseObserver)

selectUser

default void selectUser(SelectUserRequest request,
                        io.grpc.stub.StreamObserver<SelectUserResponse> responseObserver)

operatePrivilege

default void operatePrivilege(OperatePrivilegeRequest request,
                              io.grpc.stub.StreamObserver<Status> responseObserver)

operatePrivilegeV2

default void operatePrivilegeV2(OperatePrivilegeV2Request request,
                                io.grpc.stub.StreamObserver<Status> responseObserver)

selectGrant

default void selectGrant(SelectGrantRequest request,
                         io.grpc.stub.StreamObserver<SelectGrantResponse> responseObserver)

getVersion

default void getVersion(GetVersionRequest request,
                        io.grpc.stub.StreamObserver<GetVersionResponse> responseObserver)

checkHealth

default void checkHealth(CheckHealthRequest request,
                         io.grpc.stub.StreamObserver<CheckHealthResponse> responseObserver)

createResourceGroup

default void createResourceGroup(CreateResourceGroupRequest request,
                                 io.grpc.stub.StreamObserver<Status> responseObserver)

dropResourceGroup

default void dropResourceGroup(DropResourceGroupRequest request,
                               io.grpc.stub.StreamObserver<Status> responseObserver)

updateResourceGroups

default void updateResourceGroups(UpdateResourceGroupsRequest request,
                                  io.grpc.stub.StreamObserver<Status> responseObserver)

transferNode

default void transferNode(TransferNodeRequest request,
                          io.grpc.stub.StreamObserver<Status> responseObserver)

transferReplica

default void transferReplica(TransferReplicaRequest request,
                             io.grpc.stub.StreamObserver<Status> responseObserver)

listResourceGroups

default void listResourceGroups(ListResourceGroupsRequest request,
                                io.grpc.stub.StreamObserver<ListResourceGroupsResponse> responseObserver)

describeResourceGroup

default void describeResourceGroup(DescribeResourceGroupRequest request,
                                   io.grpc.stub.StreamObserver<DescribeResourceGroupResponse> responseObserver)

renameCollection

default void renameCollection(RenameCollectionRequest request,
                              io.grpc.stub.StreamObserver<Status> responseObserver)

listIndexedSegment

default void listIndexedSegment(Feder.ListIndexedSegmentRequest request,
                                io.grpc.stub.StreamObserver<Feder.ListIndexedSegmentResponse> responseObserver)

describeSegmentIndexData

default void describeSegmentIndexData(Feder.DescribeSegmentIndexDataRequest request,
                                      io.grpc.stub.StreamObserver<Feder.DescribeSegmentIndexDataResponse> responseObserver)

connect

default void connect(ConnectRequest request,
                     io.grpc.stub.StreamObserver<ConnectResponse> responseObserver)

allocTimestamp

default void allocTimestamp(AllocTimestampRequest request,
                            io.grpc.stub.StreamObserver<AllocTimestampResponse> responseObserver)

createDatabase

default void createDatabase(CreateDatabaseRequest request,
                            io.grpc.stub.StreamObserver<Status> responseObserver)

dropDatabase

default void dropDatabase(DropDatabaseRequest request,
                          io.grpc.stub.StreamObserver<Status> responseObserver)

listDatabases

default void listDatabases(ListDatabasesRequest request,
                           io.grpc.stub.StreamObserver<ListDatabasesResponse> responseObserver)

alterDatabase

default void alterDatabase(AlterDatabaseRequest request,
                           io.grpc.stub.StreamObserver<Status> responseObserver)

describeDatabase

default void describeDatabase(DescribeDatabaseRequest request,
                              io.grpc.stub.StreamObserver<DescribeDatabaseResponse> responseObserver)

replicateMessage

@Deprecated
default void replicateMessage(ReplicateMessageRequest request,
                              io.grpc.stub.StreamObserver<ReplicateMessageResponse> responseObserver)

Deprecated.

 Deprecated CDC API
 

backupRBAC

default void backupRBAC(BackupRBACMetaRequest request,
                        io.grpc.stub.StreamObserver<BackupRBACMetaResponse> responseObserver)

restoreRBAC

default void restoreRBAC(RestoreRBACMetaRequest request,
                         io.grpc.stub.StreamObserver<Status> responseObserver)

createPrivilegeGroup

default void createPrivilegeGroup(CreatePrivilegeGroupRequest request,
                                  io.grpc.stub.StreamObserver<Status> responseObserver)

dropPrivilegeGroup

default void dropPrivilegeGroup(DropPrivilegeGroupRequest request,
                                io.grpc.stub.StreamObserver<Status> responseObserver)

listPrivilegeGroups

default void listPrivilegeGroups(ListPrivilegeGroupsRequest request,
                                 io.grpc.stub.StreamObserver<ListPrivilegeGroupsResponse> responseObserver)

operatePrivilegeGroup

default void operatePrivilegeGroup(OperatePrivilegeGroupRequest request,
                                   io.grpc.stub.StreamObserver<Status> responseObserver)

runAnalyzer

default void runAnalyzer(RunAnalyzerRequest request,
                         io.grpc.stub.StreamObserver<RunAnalyzerResponse> responseObserver)

addFileResource

default void addFileResource(AddFileResourceRequest request,
                             io.grpc.stub.StreamObserver<Status> responseObserver)

removeFileResource

default void removeFileResource(RemoveFileResourceRequest request,
                                io.grpc.stub.StreamObserver<Status> responseObserver)

listFileResources

default void listFileResources(ListFileResourcesRequest request,
                               io.grpc.stub.StreamObserver<ListFileResourcesResponse> responseObserver)

addUserTags

default void addUserTags(AddUserTagsRequest request,
                         io.grpc.stub.StreamObserver<Status> responseObserver)

 Row Level Security (RLS) APIs
 

deleteUserTags

default void deleteUserTags(DeleteUserTagsRequest request,
                            io.grpc.stub.StreamObserver<Status> responseObserver)

getUserTags

default void getUserTags(GetUserTagsRequest request,
                         io.grpc.stub.StreamObserver<GetUserTagsResponse> responseObserver)

listUsersWithTag

default void listUsersWithTag(ListUsersWithTagRequest request,
                              io.grpc.stub.StreamObserver<ListUsersWithTagResponse> responseObserver)

createRowPolicy

default void createRowPolicy(CreateRowPolicyRequest request,
                             io.grpc.stub.StreamObserver<Status> responseObserver)

dropRowPolicy

default void dropRowPolicy(DropRowPolicyRequest request,
                           io.grpc.stub.StreamObserver<Status> responseObserver)

listRowPolicies

default void listRowPolicies(ListRowPoliciesRequest request,
                             io.grpc.stub.StreamObserver<ListRowPoliciesResponse> responseObserver)

updateReplicateConfiguration

default void updateReplicateConfiguration(UpdateReplicateConfigurationRequest request,
                                          io.grpc.stub.StreamObserver<Status> responseObserver)

 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

default void getReplicateConfiguration(GetReplicateConfigurationRequest request,
                                       io.grpc.stub.StreamObserver<GetReplicateConfigurationResponse> responseObserver)

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

getReplicateInfo

default void getReplicateInfo(GetReplicateInfoRequest request,
                              io.grpc.stub.StreamObserver<GetReplicateInfoResponse> responseObserver)

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

createReplicateStream

default io.grpc.stub.StreamObserver<ReplicateRequest> createReplicateStream(io.grpc.stub.StreamObserver<ReplicateResponse> responseObserver)

 CreateReplicateStream establishes a replication stream on the target Milvus cluster.
 Semantics:
   - Sets up a continuous data stream that receives replicated messages
     (DDL, insert, delete, etc.) from the source cluster via CDC.
   - Once established, the target cluster persists incoming messages into
     its WAL (Write-Ahead Log) ensuring durability and consistency.
 

computePhraseMatchSlop

default void computePhraseMatchSlop(ComputePhraseMatchSlopRequest request,
                                    io.grpc.stub.StreamObserver<ComputePhraseMatchSlopResponse> responseObserver)

createSnapshot

default void createSnapshot(CreateSnapshotRequest request,
                            io.grpc.stub.StreamObserver<Status> responseObserver)

 snapshot related
 

dropSnapshot

default void dropSnapshot(DropSnapshotRequest request,
                          io.grpc.stub.StreamObserver<Status> responseObserver)

listSnapshots

default void listSnapshots(ListSnapshotsRequest request,
                           io.grpc.stub.StreamObserver<ListSnapshotsResponse> responseObserver)

describeSnapshot

default void describeSnapshot(DescribeSnapshotRequest request,
                              io.grpc.stub.StreamObserver<DescribeSnapshotResponse> responseObserver)

restoreSnapshot

default void restoreSnapshot(RestoreSnapshotRequest request,
                             io.grpc.stub.StreamObserver<RestoreSnapshotResponse> responseObserver)

getRestoreSnapshotState

default void getRestoreSnapshotState(GetRestoreSnapshotStateRequest request,
                                     io.grpc.stub.StreamObserver<GetRestoreSnapshotStateResponse> responseObserver)

listRestoreSnapshotJobs

default void listRestoreSnapshotJobs(ListRestoreSnapshotJobsRequest request,
                                     io.grpc.stub.StreamObserver<ListRestoreSnapshotJobsResponse> responseObserver)

alterCollectionSchema

default void alterCollectionSchema(AlterCollectionSchemaRequest request,
                                   io.grpc.stub.StreamObserver<AlterCollectionSchemaResponse> responseObserver)

batchUpdateManifest

default void batchUpdateManifest(BatchUpdateManifestRequest request,
                                 io.grpc.stub.StreamObserver<Status> responseObserver)

refreshExternalCollection

default void refreshExternalCollection(RefreshExternalCollectionRequest request,
                                       io.grpc.stub.StreamObserver<RefreshExternalCollectionResponse> responseObserver)

 External Collection APIs
 

getRefreshExternalCollectionProgress

default void getRefreshExternalCollectionProgress(GetRefreshExternalCollectionProgressRequest request,
                                                  io.grpc.stub.StreamObserver<GetRefreshExternalCollectionProgressResponse> responseObserver)

listRefreshExternalCollectionJobs

default void listRefreshExternalCollectionJobs(ListRefreshExternalCollectionJobsRequest request,
                                               io.grpc.stub.StreamObserver<ListRefreshExternalCollectionJobsResponse> responseObserver)