MilvusClient

withTimeout(long timeout, TimeUnit timeoutUnit)

Timeout setting for RPC call.

timeout: The timeout period when invoking a method.

timeoutUnit: The unit for timeout.

MilvusClient

withRetry(RetryParam retryParam)

Sets the parameters for retry.

retryParam: Parameter for retry on failure.

MilvusClient

close(long maxWaitSeconds)

Disconnects from a Milvus server with a configurable timeout value. Call this method before the application terminates.This method throws an InterruptedException exception if it is interrupted.

maxWaitSeconds: The timeout period to wait for the RPC channel to close.

N/A

setLogLevel(LogLevel level)

Set log level in runtime.Note: this method cannot change the log level configured by log4j configurations. It only hides some logs inside the MilvusClient class.

level: A log level

N/A

withHost(String host)

Sets the host name or address.

host: The name or address of the host.

withPort(int port)

Sets the connection port.
The value must be greater than zero and less than 65536.

port: The connection port.

withUri(String uri)

Sets the uri of remote service.

uri: The uri of remote service.

withToken(String token)

Sets the token of remote service.

token: serving as the key for identification and authentication purposes.

withDatabaseName(String databaseName)

Sets the database name. database name can be null for default database.

databaseName: The database name.

withConnectTimeout(long connectTimeout, TimeUnit timeUnit)

Sets the connection timeout value of client channel. The timeout value must be greater than zero. The default value is 10 seconds.

connectTimeout: The connection timeout period.
timeUnit: The unit of timeout.

withKeepAliveTime(long keepAliveTime, TimeUnit timeUnit)

Sets the keep-alive time value of the client channel. The time value must be greater than zero. The default value is 55 seconds.

keepAliveTime: The keep-alive time period.
timeUnit: The unit of time.

withKeepAliveTimeout(long keepAliveTimeout, TimeUnit timeUnit)

Sets the keep-alive timeout value of client channel. The timeout value must be greater than zero. The default value is 20 seconds.

keepAliveTimeout: The keep-alive timeout value.
timeUnit: The unit of timeout.

keepAliveWithoutCalls(boolean enable)

Enables the keep-alive function for the client channel. The default value is false.

enable: Boolean value to indicate if the keep-alive function is enabled. The keep-alive function is enabled if the value is set to true.

secure(boolean enable)
withSecure(boolean enable)

Enables security for the client channel.

enable: Security is enabled if the value is set to true.

withIdleTimeout(long idleTimeout, TimeUnit timeUnit)

Sets the value of idle timeout of the client channel. The timeout value must be greater than zero. The default value is 24 hours.

idleTimeout: The idle timeout period of the client channel.
timeUnit: The unit of timeout.

withRpcDeadline(long deadline, TimeUnit timeUnit)

Set a deadline for how long you are willing to wait for a reply from the server.
With a deadline setting, the client will wait when encounter fast RPC fail caused by network fluctuations.
The deadline value must be larger than or equal to zero. Default value is 0, deadline is disabled.

deadline: deadline value
timeUnit: deadline unit

withAuthorization(String username, String password)

Sets the username and password for this connection.

username: The username of the current user.
password: The password corresponding to the username.

withClientKeyPath(String clientKeyPath)

Set the client.key path for tls two-way authentication, only takes effect when "secure" is True.

clientKeyPath: The local path of client.key

withClientPemPath(String clientPemPath)

Set the client.pem path for tls two-way authentication, only takes effect when "secure" is True.

clientPemPath: The local path of client.pem

withCaPemPath(String caPemPath)

Set the ca.pem path for tls two-way authentication, only takes effect when "secure" is True.

caPemPath: The local path of ca.pem

withServerPemPath(String serverPemPath)

Set the server.pem path for tls one-way authentication, only takes effect when "secure" is True.

serverPemPath: The local path of server.pem

withServerName(String serverName)

Set target name override for SSL host name checking, only takes effect when "secure" is True.
Note: this value is passed to grpc.ssltargetname_override

serverName: The override name for SSL host.

build()

Constructs a ConnectParam object.

N/A

withMaxRetryTimes(int maxRetryTimes)

Sets the max retry times on failure.Default value is 75.

maxRetryTimes: The maxinum times to retry.

withInitialBackOffMs(long initialBackOffMs)

Sets the first time interval between two retries, units: millisecond. Default value is 10ms.

initialBackOffMs: Retry initial interval value in milliseconds.

withMaxBackOffMs(long maxBackOffMs)

Sets the maximum time interval between two retries, units: millisecond. Default value is 3000ms.

maxBackOffMs: Retry maximum interval value in milliseconds.

withBackOffMultiplier(int backOffMultiplier)

Sets multiplier to increase time interval after each retry. Default value is 3.

backOffMultiplier: The multiplier to increase time interval after each retry.

withRetryOnRateLimie(boolean retryOnRateLimie)

Sets whether to retry when the returned error is rate limit. Default value is true.

retryOnRateLimit: Whether to retry when the returned error is rate limit.

build()

Constructs a RetryParam object.

N/A