Package io.milvus.grpc

Class MilvusServiceGrpc.MilvusServiceStub

java.lang.Object

io.grpc.stub.AbstractStub<S>

io.grpc.stub.AbstractAsyncStub<MilvusServiceGrpc.MilvusServiceStub>

io.milvus.grpc.MilvusServiceGrpc.MilvusServiceStub

Enclosing class:

MilvusServiceGrpc

public static final class MilvusServiceGrpc.MilvusServiceStub
extends io.grpc.stub.AbstractAsyncStub<MilvusServiceGrpc.MilvusServiceStub>

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

Methods inherited from class io.grpc.stub.AbstractAsyncStub

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.MilvusServiceStub build(io.grpc.Channel channel,
                                                    io.grpc.CallOptions callOptions)

Specified by:

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

createCollection

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

dropCollection

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

hasCollection

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

loadCollection

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

releaseCollection

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

describeCollection

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

batchDescribeCollection

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

getCollectionStatistics

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

showCollections

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

alterCollection

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

alterCollectionField

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

addCollectionFunction

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

alterCollectionFunction

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

dropCollectionFunction

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

truncateCollection

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

createPartition

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

dropPartition

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

hasPartition

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

loadPartitions

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

releasePartitions

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

getPartitionStatistics

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

showPartitions

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

getLoadingProgress

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

getLoadState

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

createAlias

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

dropAlias

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

alterAlias

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

describeAlias

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

listAliases

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

createIndex

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

alterIndex

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

describeIndex

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

getIndexStatistics

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

getIndexState

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

Deprecated.

 Deprecated: use DescribeIndex instead
 

getIndexBuildProgress

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

Deprecated.

 Deprecated: use DescribeIndex instead
 

dropIndex

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

insert

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

delete

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

upsert

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

search

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

hybridSearch

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

flush

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

query

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

calcDistance

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

flushAll

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

addCollectionField

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

getFlushState

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

getFlushAllState

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

getPersistentSegmentInfo

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

getQuerySegmentInfo

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

getReplicas

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

dummy

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

registerLink

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

 TODO: remove
 

getMetrics

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

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

getComponentStates

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

loadBalance

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

getCompactionState

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

manualCompaction

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

getCompactionStateWithPlans

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

import_

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

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

getImportState

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

listImportTasks

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

createCredential

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

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

updateCredential

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

deleteCredential

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

listCredUsers

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

createRole

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

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

dropRole

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

operateUserRole

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

selectRole

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

selectUser

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

operatePrivilege

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

operatePrivilegeV2

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

selectGrant

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

getVersion

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

checkHealth

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

createResourceGroup

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

dropResourceGroup

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

updateResourceGroups

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

transferNode

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

transferReplica

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

listResourceGroups

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

describeResourceGroup

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

renameCollection

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

listIndexedSegment

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

describeSegmentIndexData

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

connect

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

allocTimestamp

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

createDatabase

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

dropDatabase

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

listDatabases

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

alterDatabase

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

describeDatabase

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

replicateMessage

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

Deprecated.

 Deprecated CDC API
 

backupRBAC

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

restoreRBAC

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

createPrivilegeGroup

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

dropPrivilegeGroup

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

listPrivilegeGroups

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

operatePrivilegeGroup

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

runAnalyzer

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

addFileResource

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

removeFileResource

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

listFileResources

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

addUserTags

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

 Row Level Security (RLS) APIs
 

deleteUserTags

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

getUserTags

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

listUsersWithTag

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

createRowPolicy

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

dropRowPolicy

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

listRowPolicies

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

updateReplicateConfiguration

public 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

public 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

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

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

createReplicateStream

public 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

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

createSnapshot

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

 snapshot related
 

dropSnapshot

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

listSnapshots

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

describeSnapshot

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

restoreSnapshot

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

getRestoreSnapshotState

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

listRestoreSnapshotJobs

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

alterCollectionSchema

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

batchUpdateManifest

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

refreshExternalCollection

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

 External Collection APIs
 

getRefreshExternalCollectionProgress

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

listRefreshExternalCollectionJobs

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