Package io.milvus.client
Class MilvusServiceClient
- java.lang.Object
-
- io.milvus.client.AbstractMilvusGrpcClient
-
- io.milvus.client.MilvusServiceClient
-
- All Implemented Interfaces:
MilvusClient
public class MilvusServiceClient extends AbstractMilvusGrpcClient
-
-
Constructor Summary
Constructors Constructor Description MilvusServiceClient(@NonNull ConnectParam connectParam)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected io.milvus.grpc.MilvusServiceGrpc.MilvusServiceBlockingStub
blockingStub()
protected boolean
clientIsReady()
void
close(long maxWaitSeconds)
Disconnects from a Milvus server with configurable timeout.protected io.milvus.grpc.MilvusServiceGrpc.MilvusServiceFutureStub
futureStub()
MilvusClient
withTimeout(long timeout, java.util.concurrent.TimeUnit timeoutUnit)
Timeout setting for rpc call.-
Methods inherited from class io.milvus.client.AbstractMilvusGrpcClient
addUserToRole, alterAlias, bulkInsert, checkHealth, createAlias, createCollection, createCredential, createIndex, createPartition, createRole, delete, deleteCredential, describeCollection, describeIndex, dropAlias, dropCollection, dropIndex, dropPartition, dropRole, flush, getBulkInsertState, getCollectionStatistics, getCompactionState, getCompactionStateWithPlans, getFlushState, getIndexBuildProgress, getIndexState, getLoadingProgress, getMetrics, getPartitionStatistics, getPersistentSegmentInfo, getQuerySegmentInfo, getReplicas, getVersion, grantRolePrivilege, hasCollection, hasPartition, insert, insertAsync, listBulkInsertTasks, listCredUsers, loadBalance, loadCollection, loadPartitions, manualCompact, query, queryAsync, releaseCollection, releasePartitions, removeUserFromRole, revokeRolePrivilege, search, searchAsync, selectGrantForRole, selectGrantForRoleAndObject, selectRole, selectUser, showCollections, showPartitions, updateCredential
-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
Methods inherited from interface io.milvus.client.MilvusClient
close
-
-
-
-
Constructor Detail
-
MilvusServiceClient
public MilvusServiceClient(@NonNull @NonNull ConnectParam connectParam)
-
-
Method Detail
-
blockingStub
protected io.milvus.grpc.MilvusServiceGrpc.MilvusServiceBlockingStub blockingStub()
- Specified by:
blockingStub
in classAbstractMilvusGrpcClient
-
futureStub
protected io.milvus.grpc.MilvusServiceGrpc.MilvusServiceFutureStub futureStub()
- Specified by:
futureStub
in classAbstractMilvusGrpcClient
-
clientIsReady
protected boolean clientIsReady()
- Specified by:
clientIsReady
in classAbstractMilvusGrpcClient
-
close
public void close(long maxWaitSeconds) throws java.lang.InterruptedException
Description copied from interface:MilvusClient
Disconnects from a Milvus server with configurable timeout.- Parameters:
maxWaitSeconds
- timeout unit: second- Throws:
java.lang.InterruptedException
-
withTimeout
public MilvusClient withTimeout(long timeout, java.util.concurrent.TimeUnit timeoutUnit)
Description copied from interface:MilvusClient
Timeout setting for rpc call.- Parameters:
timeout
- set time waiting for a rpc call.timeoutUnit
- time unit
-
-