Package io.tarantool.driver.core.connection

Class TarantoolConnectionFactory

java.lang.Object

io.tarantool.driver.core.connection.TarantoolConnectionFactory

public class TarantoolConnectionFactory
extends Object

Manages instantiation and connection procedures for Tarantool server connections

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	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

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