io.picodata.driver.core.connection

Class TarantoolConnectionFactory

java.lang.Object

io.picodata.driver.core.connection.TarantoolConnectionFactory

public class TarantoolConnectionFactory
extends Object

Manages instantiation and connection procedures for Tarantool server connections

Field Summary

Fields

Modifier and Type	Field and Description
protected io.netty.bootstrap.Bootstrap	bootstrap
protected TarantoolClientConfig	config
protected ScheduledExecutorService	timeoutScheduler

Constructor Summary

Constructors

Constructor and Description
TarantoolConnectionFactory(TarantoolClientConfig config, io.netty.bootstrap.Bootstrap bootstrap, ScheduledExecutorService timeoutScheduler) Basic constructor.

Method Summary

Modifier and Type	Method and Description
Collection<CompletableFuture<TarantoolConnection>>	multiConnection(InetSocketAddress serverAddress, int connections, TarantoolConnectionListeners connectionListeners) Create several connections and return their futures
CompletableFuture<TarantoolConnection>	singleConnection(InetSocketAddress serverAddress, TarantoolConnectionListeners connectionListeners) Create single connection and return connection future

Methods inherited from class java.lang.Object

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

Field Detail

config

protected final TarantoolClientConfig config

bootstrap

protected final io.netty.bootstrap.Bootstrap bootstrap

timeoutScheduler

protected final ScheduledExecutorService timeoutScheduler

Constructor Detail

TarantoolConnectionFactory

public TarantoolConnectionFactory(TarantoolClientConfig config,
                                  io.netty.bootstrap.Bootstrap bootstrap,
                                  ScheduledExecutorService timeoutScheduler)

Basic constructor.

Parameters:

config - Tarantool client config

bootstrap - prepared Netty's bootstrap

timeoutScheduler - scheduled executor for limiting the connection tasks by timeout

Method Detail

singleConnection

public CompletableFuture<TarantoolConnection> singleConnection(InetSocketAddress serverAddress,
                                                               TarantoolConnectionListeners connectionListeners)

Create single connection and return connection future

Parameters:

serverAddress - Tarantool server address to connect

connectionListeners - listeners for the event of establishing the connection

Returns:

connection future

multiConnection

public Collection<CompletableFuture<TarantoolConnection>> multiConnection(InetSocketAddress serverAddress,
                                                                          int connections,
                                                                          TarantoolConnectionListeners connectionListeners)

Create several connections and return their futures

Parameters:

serverAddress - Tarantool server address to connect

connections - number of connections to create

connectionListeners - listeners for the event of establishing the connection

Returns:

a collection with specified number of connection futures