Package io.tarantool.driver.core.connection

Class TarantoolClusterConnectionManager

java.lang.Object

io.tarantool.driver.core.connection.AbstractTarantoolConnectionManager

io.tarantool.driver.core.connection.TarantoolClusterConnectionManager

All Implemented Interfaces:

TarantoolConnectionManager, AutoCloseable

public class TarantoolClusterConnectionManager
extends AbstractTarantoolConnectionManager

Implementation of AbstractTarantoolConnectionManager, aware of connecting to the Tarantool cluster

Constructor Summary

Constructors

Constructor	Description
TarantoolClusterConnectionManager(TarantoolClientConfig config, TarantoolConnectionFactory connectionFactory, TarantoolConnectionListeners listeners, TarantoolClusterAddressProvider addressProvider)	Basic constructor.

Method Summary

Modifier and Type	Method	Description
void	close()
protected Collection<TarantoolServerAddress>	getAddresses()	Get server addresses to connect to.

Methods inherited from class io.tarantool.driver.core.connection.AbstractTarantoolConnectionManager

getConnection, refresh

Methods inherited from class java.lang.Object

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

Constructor Detail

TarantoolClusterConnectionManager

public TarantoolClusterConnectionManager(TarantoolClientConfig config,
                                         TarantoolConnectionFactory connectionFactory,
                                         TarantoolConnectionListeners listeners,
                                         TarantoolClusterAddressProvider addressProvider)

Basic constructor.

Parameters:

config - client configuration

connectionFactory - manages instantiation of Tarantool server connections

listeners - are invoked after connection is established

addressProvider - provides Tarantool server nodes addresses

Method Detail

getAddresses

protected Collection<TarantoolServerAddress> getAddresses()

Description copied from class: AbstractTarantoolConnectionManager

Get server addresses to connect to. They must belong to one cluster and contain the information necessary for the internal ConnectionSelectionStrategy instance.

Specified by:

getAddresses in class AbstractTarantoolConnectionManager

Returns:

Tarantool server addresses

close

public void close()

Specified by:

close in interface AutoCloseable

Overrides:

close in class AbstractTarantoolConnectionManager