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 and Description
MilvusServiceClient(@NonNull ConnectParam connectParam)

Method Summary

Modifier and Type	Method and 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, alterCollection, bulkInsert, checkHealth, createAlias, createCollection, createCredential, createDatabase, createIndex, createPartition, createRole, delete, deleteCredential, describeCollection, describeIndex, dropAlias, dropCollection, dropDatabase, dropIndex, dropPartition, dropRole, flush, flushAll, getBulkInsertState, getCollectionStatistics, getCompactionState, getCompactionStateWithPlans, getFlushAllState, getFlushState, getIndexBuildProgress, getIndexState, getLoadingProgress, getLoadState, getMetrics, getPartitionStatistics, getPersistentSegmentInfo, getQuerySegmentInfo, getReplicas, getVersion, grantRolePrivilege, hasCollection, hasPartition, insert, insertAsync, listBulkInsertTasks, listCredUsers, listDatabases, loadBalance, loadCollection, loadPartitions, manualCompact, query, queryAsync, releaseCollection, releasePartitions, removeUserFromRole, renameCollection, 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 class AbstractMilvusGrpcClient

futureStub

protected io.milvus.grpc.MilvusServiceGrpc.MilvusServiceFutureStub futureStub()

Specified by:

futureStub in class AbstractMilvusGrpcClient

clientIsReady

protected boolean clientIsReady()

Specified by:

clientIsReady in class AbstractMilvusGrpcClient

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