io.picodata.driver.core

Class ClusterTarantoolClient<T extends Packable,R extends Collection<T>>

java.lang.Object

io.picodata.driver.core.AbstractTarantoolClient<T,R>

io.picodata.driver.core.ClusterTarantoolClient<T,R>

Type Parameters:

T - target tuple type

R - target tuple collection type

All Implemented Interfaces:

TarantoolCallOperations, TarantoolClient<T,R>, TarantoolEvalOperations, AutoCloseable

Direct Known Subclasses:

ClusterTarantoolTupleClient

public abstract class ClusterTarantoolClient<T extends Packable,R extends Collection<T>>
extends AbstractTarantoolClient<T,R>

Main class for connecting to a cluster of Tarantool servers. Provides basic API for interacting with the database and manages connections. Connects to all configured Tarantool server addresses simultaneously and dynamically selects the target server for performing the next request accordingly to the provided connection selection strategy. The credentials for connecting to each server are expected to be the same.

Constructor Summary

Constructors

Constructor and Description
ClusterTarantoolClient(TarantoolClientConfig config, TarantoolClusterAddressProvider addressProvider) Create a client.

Method Summary

Modifier and Type	Method and Description
protected TarantoolConnectionManager	connectionManager(TarantoolClientConfig config, TarantoolConnectionFactory connectionFactory, TarantoolConnectionListeners listeners) Provides a connection manager for Tarantool server connections
protected TarantoolClusterAddressProvider	getAddressProvider()

Methods inherited from class io.picodata.driver.core.AbstractTarantoolClient

call, call, call, call, call, call, callForMultiResult, callForMultiResult, callForMultiResult, callForMultiResult, callForMultiResult, callForMultiResult, callForMultiResult, callForMultiResult, callForMultiResult, callForSingleResult, callForSingleResult, callForSingleResult, callForSingleResult, callForSingleResult, callForSingleResult, callForSingleResult, callForSingleResult, callForSingleResult, callForTupleResult, callForTupleResult, callForTupleResult, close, eval, eval, eval, eval, eval, getBootstrap, getConfig, getConnectionListeners, getResultMapperFactoryFactory, getVersion, metadata, metadataProvider, refresh, space, space, spaceOperations

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ClusterTarantoolClient

public ClusterTarantoolClient(TarantoolClientConfig config,
                              TarantoolClusterAddressProvider addressProvider)

Create a client. The server address for connecting to the server is specified by the passed address provider.

Parameters:

config - the client configuration

addressProvider - provides Tarantool server address for connection

See Also:

TarantoolClientConfig

Method Detail

connectionManager

protected TarantoolConnectionManager connectionManager(TarantoolClientConfig config,
                                                       TarantoolConnectionFactory connectionFactory,
                                                       TarantoolConnectionListeners listeners)

Description copied from class: AbstractTarantoolClient

Provides a connection manager for Tarantool server connections

Specified by:

connectionManager in class AbstractTarantoolClient<T extends Packable,R extends Collection<T>>

Parameters:

config - contains Tarantool client configuration options

connectionFactory - provides helper methods for connection instantiation

listeners - listeners which will be invoked once all connections are established

Returns:

connection manager

getAddressProvider

protected TarantoolClusterAddressProvider getAddressProvider()