MilvusClient

MilvusClient is an abstract interface of the Milvus client. MilvusServiceClient class is the implementation.

package io.milvus.client;
MilvusServiceClient(ConnectParam connectParam)

Methods of MilvusClient for connection:

Method	Description	Parameters	Returns
withTimeout(long timeout, TimeUnit timeoutUnit)	The timeout setting for RPC call.	timeout: The timeout period for invoking a method. timeoutUnit: The unit for timeout.	MilvusClient
close(long maxWaitSeconds)	Disconnects from a Milvus server with 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 until the RPC channel closes.	N/A
setLogLevel(LogLevel level)	Sets the log level at runtime.	level: The log level at runtime.	N/A

ConnectParam

Use the ConnectParam.Builder to construct a ConnectParam object for the MilvusServiceClient.

import io.milvus.param.ConnectParam;
ConnectParam.Builder builder = ConnectParam.newBuilder();

Methods of ConnectParam.Builder:

Method	Description	Patameters
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.
withDatabaseName(String databaseName)	Sets the name of the database to use for the connection.	databaseName: The name of the target database to connect.
withConnectTimeout(long connectTimeout, TimeUnit timeUnit)	Sets the connection timeout value of client channel. The timeout value must be greater than zero.	connectTimeout: The connection timeout period. timeUnit: The unit of timeout.
withKeepAliveTime(long keepAliveTime, TimeUnit timeUnit)	Sets the keep-alive timeout value of the client channel. The timeout value must be greater than zero.	keepAliveTime: The keep-alive timeout period. timeUnit: The unit of timeout.
keepAliveWithoutCalls(boolean enable)	Enables the keep-alive function for the client channel.	enable: A 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.	idleTimeout: The idle timeout period of the client channel. timeUnit: The unit of timeout.
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)	Sets the path to the client key file for two-way authentication. This method applies only if the secure method is True	clientKeyPath: Path to the client key file.
withClientPemPath(String clientPemPath)	Sets the path to the client PEM file for two-way authentication. This method applies only if the secure method is True	clientPemPath: Path to the client PEM file.
withCaPemPath(String caPemPath)	Sets the path to the CA PEM file for two-way authentication. This method applies only if the secure method is True	caPemPath: Path to the CA PEM file.
withServerPemPath(String serverPemPath)	Sets the path to the server PEM file for two-way authentication. This method applies only if the secure method is True	serverPemPath: Path to the server PEM file.
build()	Constructs a ConnectParam object.	N/A

The ConnectParam.Builder.build() can throw the following exceptions:

• ParamException: error if the parameter is invalid.

Example

• Without timeout setting for RPC call:

import io.milvus.param.*;
import io.milvus.client.*;

ConnectParam connectParam = ConnectParam.newBuilder()
    .withHost("localhost")
    .withPort(19530)
    .withAuthorization("root", "Milvus")
    .build();
MilvusClient client = new MilvusServiceClient(connectParam);

ShowCollectionsParam param = ShowCollectionsParam.newBuilder().build()
R<ShowCollectionsResponse> response = client.showCollections(param);

client.close(1);

• With timeout setting for RPC call:

import io.milvus.param.*;
import io.milvus.client.*;
import java.util.concurrent.TimeUnit;

ConnectParam connectParam = ConnectParam.newBuilder()
    .withHost("localhost")
    .withPort(19530)
    .withAuthorization("root", "Milvus")
    .build();
MilvusClient client = new MilvusServiceClient(connectParam);

ShowCollectionsParam param = ShowCollectionsParam.newBuilder().build();
R<ShowCollectionsResponse> response = client.withTimeout(2, TimeUnit.SECONDS).showCollections(param);

client.close(1);