Package io.milvus.grpc

Class MilvusServiceGrpc.MilvusServiceBlockingStub

java.lang.Object

io.grpc.stub.AbstractStub<S>

io.grpc.stub.AbstractBlockingStub<MilvusServiceGrpc.MilvusServiceBlockingStub>

io.milvus.grpc.MilvusServiceGrpc.MilvusServiceBlockingStub

Enclosing class:

MilvusServiceGrpc

public static final class MilvusServiceGrpc.MilvusServiceBlockingStub
extends io.grpc.stub.AbstractBlockingStub<MilvusServiceGrpc.MilvusServiceBlockingStub>

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

Methods inherited from class io.grpc.stub.AbstractBlockingStub

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

Specified by:

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

createCollection

public Status createCollection(CreateCollectionRequest request)

dropCollection

public Status dropCollection(DropCollectionRequest request)

hasCollection

public BoolResponse hasCollection(HasCollectionRequest request)

loadCollection

public Status loadCollection(LoadCollectionRequest request)

releaseCollection

public Status releaseCollection(ReleaseCollectionRequest request)

describeCollection

public DescribeCollectionResponse describeCollection(DescribeCollectionRequest request)

batchDescribeCollection

public BatchDescribeCollectionResponse batchDescribeCollection(BatchDescribeCollectionRequest request)

getCollectionStatistics

public GetCollectionStatisticsResponse getCollectionStatistics(GetCollectionStatisticsRequest request)

showCollections

public ShowCollectionsResponse showCollections(ShowCollectionsRequest request)

alterCollection

public Status alterCollection(AlterCollectionRequest request)

alterCollectionField

public Status alterCollectionField(AlterCollectionFieldRequest request)

addCollectionFunction

public Status addCollectionFunction(AddCollectionFunctionRequest request)

alterCollectionFunction

public Status alterCollectionFunction(AlterCollectionFunctionRequest request)

dropCollectionFunction

public Status dropCollectionFunction(DropCollectionFunctionRequest request)

truncateCollection

public TruncateCollectionResponse truncateCollection(TruncateCollectionRequest request)

createPartition

public Status createPartition(CreatePartitionRequest request)

dropPartition

public Status dropPartition(DropPartitionRequest request)

hasPartition

public BoolResponse hasPartition(HasPartitionRequest request)

loadPartitions

public Status loadPartitions(LoadPartitionsRequest request)

releasePartitions

public Status releasePartitions(ReleasePartitionsRequest request)

getPartitionStatistics

public GetPartitionStatisticsResponse getPartitionStatistics(GetPartitionStatisticsRequest request)

showPartitions

public ShowPartitionsResponse showPartitions(ShowPartitionsRequest request)

getLoadingProgress

public GetLoadingProgressResponse getLoadingProgress(GetLoadingProgressRequest request)

getLoadState

public GetLoadStateResponse getLoadState(GetLoadStateRequest request)

createAlias

public Status createAlias(CreateAliasRequest request)

dropAlias

public Status dropAlias(DropAliasRequest request)

alterAlias

public Status alterAlias(AlterAliasRequest request)

describeAlias

public DescribeAliasResponse describeAlias(DescribeAliasRequest request)

listAliases

public ListAliasesResponse listAliases(ListAliasesRequest request)

createIndex

public Status createIndex(CreateIndexRequest request)

alterIndex

public Status alterIndex(AlterIndexRequest request)

describeIndex

public DescribeIndexResponse describeIndex(DescribeIndexRequest request)

getIndexStatistics

public GetIndexStatisticsResponse getIndexStatistics(GetIndexStatisticsRequest request)

getIndexState

@Deprecated
public GetIndexStateResponse getIndexState(GetIndexStateRequest request)

Deprecated.

 Deprecated: use DescribeIndex instead
 

getIndexBuildProgress

@Deprecated
public GetIndexBuildProgressResponse getIndexBuildProgress(GetIndexBuildProgressRequest request)

Deprecated.

 Deprecated: use DescribeIndex instead
 

dropIndex

public Status dropIndex(DropIndexRequest request)

insert

public MutationResult insert(InsertRequest request)

delete

public MutationResult delete(DeleteRequest request)

upsert

public MutationResult upsert(UpsertRequest request)

search

public SearchResults search(SearchRequest request)

hybridSearch

public SearchResults hybridSearch(HybridSearchRequest request)

flush

public FlushResponse flush(FlushRequest request)

query

public QueryResults query(QueryRequest request)

calcDistance

public CalcDistanceResults calcDistance(CalcDistanceRequest request)

flushAll

public FlushAllResponse flushAll(FlushAllRequest request)

addCollectionField

public Status addCollectionField(AddCollectionFieldRequest request)

getFlushState

public GetFlushStateResponse getFlushState(GetFlushStateRequest request)

getFlushAllState

public GetFlushAllStateResponse getFlushAllState(GetFlushAllStateRequest request)

getPersistentSegmentInfo

public GetPersistentSegmentInfoResponse getPersistentSegmentInfo(GetPersistentSegmentInfoRequest request)

getQuerySegmentInfo

public GetQuerySegmentInfoResponse getQuerySegmentInfo(GetQuerySegmentInfoRequest request)

getReplicas

public GetReplicasResponse getReplicas(GetReplicasRequest request)

dummy

public DummyResponse dummy(DummyRequest request)

registerLink

public RegisterLinkResponse registerLink(RegisterLinkRequest request)

 TODO: remove
 

getMetrics

public GetMetricsResponse getMetrics(GetMetricsRequest request)

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

getComponentStates

public ComponentStates getComponentStates(GetComponentStatesRequest request)

loadBalance

public Status loadBalance(LoadBalanceRequest request)

getCompactionState

public GetCompactionStateResponse getCompactionState(GetCompactionStateRequest request)

manualCompaction

public ManualCompactionResponse manualCompaction(ManualCompactionRequest request)

getCompactionStateWithPlans

public GetCompactionPlansResponse getCompactionStateWithPlans(GetCompactionPlansRequest request)

import_

public ImportResponse import_(ImportRequest request)

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

getImportState

public GetImportStateResponse getImportState(GetImportStateRequest request)

listImportTasks

public ListImportTasksResponse listImportTasks(ListImportTasksRequest request)

createCredential

public Status createCredential(CreateCredentialRequest request)

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

updateCredential

public Status updateCredential(UpdateCredentialRequest request)

deleteCredential

public Status deleteCredential(DeleteCredentialRequest request)

listCredUsers

public ListCredUsersResponse listCredUsers(ListCredUsersRequest request)

createRole

public Status createRole(CreateRoleRequest request)

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

dropRole

public Status dropRole(DropRoleRequest request)

operateUserRole

public Status operateUserRole(OperateUserRoleRequest request)

selectRole

public SelectRoleResponse selectRole(SelectRoleRequest request)

selectUser

public SelectUserResponse selectUser(SelectUserRequest request)

operatePrivilege

public Status operatePrivilege(OperatePrivilegeRequest request)

operatePrivilegeV2

public Status operatePrivilegeV2(OperatePrivilegeV2Request request)

selectGrant

public SelectGrantResponse selectGrant(SelectGrantRequest request)

getVersion

public GetVersionResponse getVersion(GetVersionRequest request)

checkHealth

public CheckHealthResponse checkHealth(CheckHealthRequest request)

createResourceGroup

public Status createResourceGroup(CreateResourceGroupRequest request)

dropResourceGroup

public Status dropResourceGroup(DropResourceGroupRequest request)

updateResourceGroups

public Status updateResourceGroups(UpdateResourceGroupsRequest request)

transferNode

public Status transferNode(TransferNodeRequest request)

transferReplica

public Status transferReplica(TransferReplicaRequest request)

listResourceGroups

public ListResourceGroupsResponse listResourceGroups(ListResourceGroupsRequest request)

describeResourceGroup

public DescribeResourceGroupResponse describeResourceGroup(DescribeResourceGroupRequest request)

renameCollection

public Status renameCollection(RenameCollectionRequest request)

listIndexedSegment

public Feder.ListIndexedSegmentResponse listIndexedSegment(Feder.ListIndexedSegmentRequest request)

describeSegmentIndexData

public Feder.DescribeSegmentIndexDataResponse describeSegmentIndexData(Feder.DescribeSegmentIndexDataRequest request)

connect

public ConnectResponse connect(ConnectRequest request)

allocTimestamp

public AllocTimestampResponse allocTimestamp(AllocTimestampRequest request)

createDatabase

public Status createDatabase(CreateDatabaseRequest request)

dropDatabase

public Status dropDatabase(DropDatabaseRequest request)

listDatabases

public ListDatabasesResponse listDatabases(ListDatabasesRequest request)

alterDatabase

public Status alterDatabase(AlterDatabaseRequest request)

describeDatabase

public DescribeDatabaseResponse describeDatabase(DescribeDatabaseRequest request)

replicateMessage

@Deprecated
public ReplicateMessageResponse replicateMessage(ReplicateMessageRequest request)

Deprecated.

 Deprecated CDC API
 

backupRBAC

public BackupRBACMetaResponse backupRBAC(BackupRBACMetaRequest request)

restoreRBAC

public Status restoreRBAC(RestoreRBACMetaRequest request)

createPrivilegeGroup

public Status createPrivilegeGroup(CreatePrivilegeGroupRequest request)

dropPrivilegeGroup

public Status dropPrivilegeGroup(DropPrivilegeGroupRequest request)

listPrivilegeGroups

public ListPrivilegeGroupsResponse listPrivilegeGroups(ListPrivilegeGroupsRequest request)

operatePrivilegeGroup

public Status operatePrivilegeGroup(OperatePrivilegeGroupRequest request)

runAnalyzer

public RunAnalyzerResponse runAnalyzer(RunAnalyzerRequest request)

addFileResource

public Status addFileResource(AddFileResourceRequest request)

removeFileResource

public Status removeFileResource(RemoveFileResourceRequest request)

listFileResources

public ListFileResourcesResponse listFileResources(ListFileResourcesRequest request)

addUserTags

public Status addUserTags(AddUserTagsRequest request)

 Row Level Security (RLS) APIs
 

deleteUserTags

public Status deleteUserTags(DeleteUserTagsRequest request)

getUserTags

public GetUserTagsResponse getUserTags(GetUserTagsRequest request)

listUsersWithTag

public ListUsersWithTagResponse listUsersWithTag(ListUsersWithTagRequest request)

createRowPolicy

public Status createRowPolicy(CreateRowPolicyRequest request)

dropRowPolicy

public Status dropRowPolicy(DropRowPolicyRequest request)

listRowPolicies

public ListRowPoliciesResponse listRowPolicies(ListRowPoliciesRequest request)

updateReplicateConfiguration

public 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 GetReplicateConfigurationResponse getReplicateConfiguration(GetReplicateConfigurationRequest request)

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

getReplicateInfo

public GetReplicateInfoResponse getReplicateInfo(GetReplicateInfoRequest request)

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

computePhraseMatchSlop

public ComputePhraseMatchSlopResponse computePhraseMatchSlop(ComputePhraseMatchSlopRequest request)

createSnapshot

public Status createSnapshot(CreateSnapshotRequest request)

 snapshot related
 

dropSnapshot

public Status dropSnapshot(DropSnapshotRequest request)

listSnapshots

public ListSnapshotsResponse listSnapshots(ListSnapshotsRequest request)

describeSnapshot

public DescribeSnapshotResponse describeSnapshot(DescribeSnapshotRequest request)

restoreSnapshot

public RestoreSnapshotResponse restoreSnapshot(RestoreSnapshotRequest request)

getRestoreSnapshotState

public GetRestoreSnapshotStateResponse getRestoreSnapshotState(GetRestoreSnapshotStateRequest request)

listRestoreSnapshotJobs

public ListRestoreSnapshotJobsResponse listRestoreSnapshotJobs(ListRestoreSnapshotJobsRequest request)

alterCollectionSchema

public AlterCollectionSchemaResponse alterCollectionSchema(AlterCollectionSchemaRequest request)

batchUpdateManifest

public Status batchUpdateManifest(BatchUpdateManifestRequest request)

refreshExternalCollection

public RefreshExternalCollectionResponse refreshExternalCollection(RefreshExternalCollectionRequest request)

 External Collection APIs
 

getRefreshExternalCollectionProgress

public GetRefreshExternalCollectionProgressResponse getRefreshExternalCollectionProgress(GetRefreshExternalCollectionProgressRequest request)

listRefreshExternalCollectionJobs

public ListRefreshExternalCollectionJobsResponse listRefreshExternalCollectionJobs(ListRefreshExternalCollectionJobsRequest request)