io.picodata.driver.cluster

Class AbstractDiscoveryClusterAddressProvider

java.lang.Object

io.picodata.driver.cluster.AbstractDiscoveryClusterAddressProvider

All Implemented Interfaces:

TarantoolClusterAddressProvider, AutoCloseable

Direct Known Subclasses:

BinaryDiscoveryClusterAddressProvider, HTTPDiscoveryClusterAddressProvider

public abstract class AbstractDiscoveryClusterAddressProvider
extends Object
implements TarantoolClusterAddressProvider

Base class offering discovery task creation and updating of the internal collection of addresses

Constructor Summary

Constructors

Constructor and Description
AbstractDiscoveryClusterAddressProvider(TarantoolClusterDiscoveryConfig discoveryConfig)

Method Summary

Modifier and Type	Method and Description
void	close()
protected abstract Collection<TarantoolServerAddress>	discoverAddresses()
Collection<TarantoolServerAddress>	getAddresses() The collection of Tarantool server nodes which belong to the same cluster
protected TarantoolClusterDiscoveryConfig	getDiscoveryConfig()
protected ScheduledExecutorService	getExecutorService()
void	setRefreshCallback(Runnable runnable) Specify callback for refreshing connections to addresses.
protected void	startDiscoveryTask()

Methods inherited from class java.lang.Object

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

Constructor Detail

AbstractDiscoveryClusterAddressProvider

public AbstractDiscoveryClusterAddressProvider(TarantoolClusterDiscoveryConfig discoveryConfig)

Method Detail

startDiscoveryTask

protected void startDiscoveryTask()
                           throws TarantoolClientException

Throws:

TarantoolClientException

getDiscoveryConfig

protected TarantoolClusterDiscoveryConfig getDiscoveryConfig()

getExecutorService

protected ScheduledExecutorService getExecutorService()

discoverAddresses

protected abstract Collection<TarantoolServerAddress> discoverAddresses()

getAddresses

public Collection<TarantoolServerAddress> getAddresses()

Description copied from interface: TarantoolClusterAddressProvider

The collection of Tarantool server nodes which belong to the same cluster

Specified by:

getAddresses in interface TarantoolClusterAddressProvider

Returns:

collection of TarantoolServerAddress

setRefreshCallback

public void setRefreshCallback(Runnable runnable)

Description copied from interface: TarantoolClusterAddressProvider

Specify callback for refreshing connections to addresses.

For example: can be executed when provider detects changes in the list of server addresses.

Specified by:

setRefreshCallback in interface TarantoolClusterAddressProvider

Parameters:

runnable - callback for running refresh connections

close

public void close()

Specified by:

close in interface TarantoolClusterAddressProvider

Specified by:

close in interface AutoCloseable