io.picodata.driver.core

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

java.lang.Object

io.picodata.driver.core.AbstractTarantoolClient<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:

ClusterTarantoolClient

public abstract class AbstractTarantoolClient<T extends Packable,R extends Collection<T>>
extends Object
implements TarantoolClient<T,R>

Basic Tarantool client implementation. Subclasses must provide the connection manager.

Constructor Summary

Constructors

Modifier	Constructor and Description
	AbstractTarantoolClient(TarantoolClientConfig config) Create a client.
protected	AbstractTarantoolClient(TarantoolClientConfig config, ConnectionSelectionStrategyFactory selectionStrategyFactory, TarantoolConnectionListeners listeners) Deprecated.
	AbstractTarantoolClient(TarantoolClientConfig config, TarantoolConnectionListeners listeners) Create a client, specifying the connection established event listeners.

Method Summary

Modifier and Type	Method and Description
CompletableFuture<List<?>>	call(String functionName) Execute a function defined on Tarantool instance.
CompletableFuture<List<?>>	call(String functionName, Collection<?> arguments) Execute a function defined on Tarantool instance.
<T> CompletableFuture<T>	call(String functionName, Collection<?> arguments, Supplier<? extends MessagePackObjectMapper> argumentsMapperSupplier, Supplier<CallResultMapper<T,SingleValueCallResult<T>>> resultMapperSupplier) Execute a function defined on Tarantool instance.
<T> CompletableFuture<T>	call(String functionName, Collection<?> arguments, Supplier<CallResultMapper<T,SingleValueCallResult<T>>> resultMapperSupplier) Execute a function defined on Tarantool instance.
CompletableFuture<List<?>>	call(String functionName, Object... arguments) Execute a function defined on Tarantool instance, The value mapper specified in the client configuration will be used for converting the result values from MessagePack entities to objects.
<T> CompletableFuture<T>	call(String functionName, Supplier<CallResultMapper<T,SingleValueCallResult<T>>> resultMapperSupplier) Execute a function defined on Tarantool instance.
<T,R extends List<T>> CompletableFuture<R>	callForMultiResult(String functionName, Collection<?> arguments, Supplier<? extends MessagePackObjectMapper> argumentsMapperSupplier, Supplier<CallResultMapper<R,MultiValueCallResult<T,R>>> resultMapperSupplier) Execute a function defined on Tarantool instance.
<T,R extends List<T>> CompletableFuture<R>	callForMultiResult(String functionName, Collection<?> arguments, Supplier<? extends MessagePackObjectMapper> argumentsMapperSupplier, Supplier<R> resultContainerSupplier, Class<T> resultClass) Execute a function defined on Tarantool instance.
<T,R extends List<T>> CompletableFuture<R>	callForMultiResult(String functionName, Collection<?> arguments, Supplier<? extends MessagePackObjectMapper> argumentsMapperSupplier, Supplier<R> resultContainerSupplier, ValueConverter<org.msgpack.value.Value,T> valueConverter) Execute a function defined on Tarantool instance.
<T,R extends List<T>> CompletableFuture<R>	callForMultiResult(String functionName, Collection<?> arguments, Supplier<CallResultMapper<R,MultiValueCallResult<T,R>>> resultMapperSupplier) Execute a function defined on Tarantool instance.
<T,R extends List<T>> CompletableFuture<R>	callForMultiResult(String functionName, Collection<?> arguments, Supplier<R> resultContainerSupplier, Class<T> resultClass) Execute a function defined on Tarantool instance.
<T,R extends List<T>> CompletableFuture<R>	callForMultiResult(String functionName, Collection<?> arguments, Supplier<R> resultContainerSupplier, ValueConverter<org.msgpack.value.Value,T> valueConverter) Execute a function defined on Tarantool instance.
<T,R extends List<T>> CompletableFuture<R>	callForMultiResult(String functionName, Supplier<CallResultMapper<R,MultiValueCallResult<T,R>>> resultMapperSupplier) Execute a function defined on Tarantool instance.
<T,R extends List<T>> CompletableFuture<R>	callForMultiResult(String functionName, Supplier<R> resultContainerSupplier, Class<T> resultClass) Execute a function defined on Tarantool instance.
<T,R extends List<T>> CompletableFuture<R>	callForMultiResult(String functionName, Supplier<R> resultContainerSupplier, ValueConverter<org.msgpack.value.Value,T> valueConverter) Execute a function defined on Tarantool instance.
<S> CompletableFuture<S>	callForSingleResult(String functionName, Class<S> resultClass) Execute a function defined on Tarantool instance.
<S> CompletableFuture<S>	callForSingleResult(String functionName, Collection<?> arguments, Class<S> resultClass) Execute a function defined on Tarantool instance.
<S> CompletableFuture<S>	callForSingleResult(String functionName, Collection<?> arguments, Supplier<? extends MessagePackObjectMapper> argumentsMapperSupplier, Class<S> resultClass) Execute a function defined on Tarantool instance.
<S> CompletableFuture<S>	callForSingleResult(String functionName, Collection<?> arguments, Supplier<? extends MessagePackObjectMapper> argumentsMapperSupplier, Supplier<CallResultMapper<S,SingleValueCallResult<S>>> resultMapperSupplier) Execute a function defined on Tarantool instance.
<S> CompletableFuture<S>	callForSingleResult(String functionName, Collection<?> arguments, Supplier<? extends MessagePackObjectMapper> argumentsMapperSupplier, ValueConverter<org.msgpack.value.Value,S> valueConverter) Execute a function defined on Tarantool instance.
<S> CompletableFuture<S>	callForSingleResult(String functionName, Collection<?> arguments, Supplier<CallResultMapper<S,SingleValueCallResult<S>>> resultMapperSupplier) Execute a function defined on Tarantool instance.
<S> CompletableFuture<S>	callForSingleResult(String functionName, Collection<?> arguments, ValueConverter<org.msgpack.value.Value,S> valueConverter) Execute a function defined on Tarantool instance.
<S> CompletableFuture<S>	callForSingleResult(String functionName, Supplier<CallResultMapper<S,SingleValueCallResult<S>>> resultMapperSupplier) Execute a function defined on Tarantool instance.
<S> CompletableFuture<S>	callForSingleResult(String functionName, ValueConverter<org.msgpack.value.Value,S> valueConverter) Execute a function defined on Tarantool instance.
<T> CompletableFuture<TarantoolResult<T>>	callForTupleResult(String functionName, Class<T> tupleClass) Execute a function defined on Tarantool instance.
<T> CompletableFuture<TarantoolResult<T>>	callForTupleResult(String functionName, Collection<?> arguments, Class<T> tupleClass) Execute a function defined on Tarantool instance.
<T> CompletableFuture<TarantoolResult<T>>	callForTupleResult(String functionName, Collection<?> arguments, Supplier<? extends MessagePackObjectMapper> argumentsMapperSupplier, Class<T> tupleClass) Execute a function defined on Tarantool instance.
void	close()
protected abstract TarantoolConnectionManager	connectionManager(TarantoolClientConfig config, TarantoolConnectionFactory connectionFactory, TarantoolConnectionListeners listeners) Provides a connection manager for Tarantool server connections
CompletableFuture<List<?>>	eval(String expression) Execute a Lua expression in the Tarantool instance.
CompletableFuture<List<?>>	eval(String expression, Collection<?> arguments) Execute a Lua expression in the Tarantool instance.
CompletableFuture<List<?>>	eval(String expression, Collection<?> arguments, Supplier<? extends MessagePackObjectMapper> argumentsMapperSupplier, Supplier<? extends MessagePackValueMapper> resultMapperSupplier) Execute a Lua expression in the Tarantool instance.
CompletableFuture<List<?>>	eval(String expression, Collection<?> arguments, Supplier<? extends MessagePackValueMapper> resultMapperSupplier) Execute a Lua expression in the Tarantool instance.
CompletableFuture<List<?>>	eval(String expression, Supplier<? extends MessagePackValueMapper> resultMapperSupplier) Execute a Lua expression in the Tarantool instance.
protected io.netty.bootstrap.Bootstrap	getBootstrap()
TarantoolClientConfig	getConfig() Get the Tarantool client config passed to this client
TarantoolConnectionListeners	getConnectionListeners() Get collection of connection listeners.
ResultMapperFactoryFactory	getResultMapperFactoryFactory() Get the default factory for result mapper factory instances
TarantoolVersion	getVersion() Get the Tarantool server version
TarantoolMetadataOperations	metadata() Provides operations for Tarantool spaces and indexes metadata
TarantoolMetadataProvider	metadataProvider() Provides implementation of retrieving the metadata for spaces and instances from Tarantool servers
boolean	refresh() Starts the process of establishing lacking connections to each host
TarantoolSpaceOperations<T,R>	space(int spaceId) Provides CRUD and other operations for a Tarantool space
TarantoolSpaceOperations<T,R>	space(String spaceName) Provides CRUD and other operations for a Tarantool space
protected abstract TarantoolSpaceOperations<T,R>	spaceOperations(TarantoolClientConfig config, TarantoolConnectionManager connectionManager, TarantoolMetadataOperations metadata, TarantoolSpaceMetadata spaceMetadata) Creates a space API implementation instance for the specified space

Methods inherited from class java.lang.Object

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

Constructor Detail

AbstractTarantoolClient

public AbstractTarantoolClient(TarantoolClientConfig config)

Create a client.

Parameters:

config - the client configuration

See Also:

TarantoolClientConfig

AbstractTarantoolClient

protected AbstractTarantoolClient(TarantoolClientConfig config,
                                  ConnectionSelectionStrategyFactory selectionStrategyFactory,
                                  TarantoolConnectionListeners listeners)

Deprecated.

Create a client, specifying the connection established event listeners.

Parameters:

config - the client configuration

selectionStrategyFactory - instantiates strategies which provide the algorithm of selecting connections from the connection pool for performing the next request

listeners - connection established event listeners

See Also:

TarantoolClientConfig

AbstractTarantoolClient

public AbstractTarantoolClient(TarantoolClientConfig config,
                               TarantoolConnectionListeners listeners)

Create a client, specifying the connection established event listeners.

Parameters:

config - the client configuration

listeners - connection established event listeners

See Also:

TarantoolClientConfig

Method Detail

connectionManager

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

Provides a connection manager for Tarantool server connections

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

refresh

public boolean refresh()

Description copied from interface: TarantoolClient

Starts the process of establishing lacking connections to each host

Specified by:

refresh in interface TarantoolClient<T extends Packable,R extends Collection<T>>

Returns:

returns true if the establishing process has been started, else false

getVersion

public TarantoolVersion getVersion()
                            throws TarantoolClientException

Description copied from interface: TarantoolClient

Get the Tarantool server version

Specified by:

getVersion in interface TarantoolClient<T extends Packable,R extends Collection<T>>

Returns:

TarantoolVersion

Throws:

TarantoolClientException - if the client is not connected

space

public TarantoolSpaceOperations<T,R> space(String spaceName)
                                    throws TarantoolClientException

Description copied from interface: TarantoolClient

Provides CRUD and other operations for a Tarantool space

Specified by:

space in interface TarantoolClient<T extends Packable,R extends Collection<T>>

Parameters:

spaceName - name of the space, must not be null or empty

Returns:

Tarantool space operations interface

Throws:

TarantoolClientException - if the client is not connected

space

public TarantoolSpaceOperations<T,R> space(int spaceId)
                                    throws TarantoolClientException

Description copied from interface: TarantoolClient

Provides CRUD and other operations for a Tarantool space

Specified by:

space in interface TarantoolClient<T extends Packable,R extends Collection<T>>

Parameters:

spaceId - ID of the space, must be greater than 0

Returns:

Tarantool space operations implementation

Throws:

TarantoolClientException - if the client is not connected

spaceOperations

protected abstract TarantoolSpaceOperations<T,R> spaceOperations(TarantoolClientConfig config,
                                                                 TarantoolConnectionManager connectionManager,
                                                                 TarantoolMetadataOperations metadata,
                                                                 TarantoolSpaceMetadata spaceMetadata)

Creates a space API implementation instance for the specified space

Parameters:

config - Tarantool client configuration

connectionManager - configured internal connection manager

metadata - metadata operations

spaceMetadata - current space metadata

Returns:

space API implementation instance

metadata

public TarantoolMetadataOperations metadata()
                                     throws TarantoolClientException

Description copied from interface: TarantoolClient

Provides operations for Tarantool spaces and indexes metadata

Specified by:

metadata in interface TarantoolClient<T extends Packable,R extends Collection<T>>

Returns:

Tarantool metadata operations implementation

Throws:

TarantoolClientException - if the client is not connected

metadataProvider

public TarantoolMetadataProvider metadataProvider()

Description copied from interface: TarantoolClient

Provides implementation of retrieving the metadata for spaces and instances from Tarantool servers

Specified by:

metadataProvider in interface TarantoolClient<T extends Packable,R extends Collection<T>>

Returns:

metadata provider instance

call

public CompletableFuture<List<?>> call(String functionName)
                                throws TarantoolClientException

Description copied from interface: TarantoolCallOperations

Execute a function defined on Tarantool instance. The value mapper specified in the client configuration will be used for converting the result values from MessagePack entities to objects. TODO example function call

Specified by:

call in interface TarantoolCallOperations

Parameters:

functionName - function name, must not be null or empty

Returns:

some result

Throws:

TarantoolClientException - if the client is not connected or some other error occurred

call

public CompletableFuture<List<?>> call(String functionName,
                                       Object... arguments)
                                throws TarantoolClientException

Description copied from interface: TarantoolCallOperations

Execute a function defined on Tarantool instance, The value mapper specified in the client configuration will be used for converting the result values from MessagePack entities to objects.

Specified by:

call in interface TarantoolCallOperations

Parameters:

functionName - function name, must not be null or empty

arguments - vararg array of function arguments. The object mapper specified in the client configuration will be used for arguments conversion to MessagePack entities

Returns:

some result

Throws:

TarantoolClientException - if the client is not connected or some other error occurred

call

public CompletableFuture<List<?>> call(String functionName,
                                       Collection<?> arguments)
                                throws TarantoolClientException

Description copied from interface: TarantoolCallOperations

Execute a function defined on Tarantool instance. The value mapper specified in the client configuration will be used for converting the result values from MessagePack entities to objects.

Specified by:

call in interface TarantoolCallOperations

Parameters:

functionName - function name, must not be null or empty

arguments - list of function arguments. The object mapper specified in the client configuration will be used for arguments conversion to MessagePack entities

Returns:

some result

Throws:

TarantoolClientException - if the client is not connected or some other error occurred

callForTupleResult

public <T> CompletableFuture<TarantoolResult<T>> callForTupleResult(String functionName,
                                                                    Class<T> tupleClass)
                                                             throws TarantoolClientException

Description copied from interface: TarantoolCallOperations

Execute a function defined on Tarantool instance. The call result is interpreted as an array of tuples. The value mapper specified in the client configuration will be used for converting the result values from MessagePack arrays to the specified entity type.

Specified by:

callForTupleResult in interface TarantoolCallOperations

Type Parameters:

T - desired function call result type

Parameters:

functionName - function name, must not be null or empty

tupleClass - target result entity class

Returns:

some result

Throws:

TarantoolClientException - if the client is not connected or some other error occurred

call

public <T> CompletableFuture<T> call(String functionName,
                                     Supplier<CallResultMapper<T,SingleValueCallResult<T>>> resultMapperSupplier)
                              throws TarantoolClientException

Description copied from interface: TarantoolCallOperations

Execute a function defined on Tarantool instance. The call result is interpreted as an array of tuples.

Specified by:

call in interface TarantoolCallOperations

Type Parameters:

T - desired function call result type

Parameters:

functionName - function name, must not be null or empty

resultMapperSupplier - mapper supplier for result value MessagePack entity-to-object conversion

Returns:

some result

Throws:

TarantoolClientException - if the client is not connected or some other error occurred

callForTupleResult

public <T> CompletableFuture<TarantoolResult<T>> callForTupleResult(String functionName,
                                                                    Collection<?> arguments,
                                                                    Class<T> tupleClass)
                                                             throws TarantoolClientException

Description copied from interface: TarantoolCallOperations

Execute a function defined on Tarantool instance. The call result is interpreted as an array of tuples. The value mapper specified in the client configuration will be used for converting the result values from MessagePack arrays to the specified entity type.

Specified by:

callForTupleResult in interface TarantoolCallOperations

Type Parameters:

T - desired function call result type

Parameters:

functionName - function name, must not be null or empty

arguments - list of function arguments. The object mapper specified in the client configuration will be used for arguments conversion to MessagePack entities

tupleClass - target result entity class

Returns:

some result

Throws:

TarantoolClientException - if the client is not connected or some other error occurred

call

public <T> CompletableFuture<T> call(String functionName,
                                     Collection<?> arguments,
                                     Supplier<CallResultMapper<T,SingleValueCallResult<T>>> resultMapperSupplier)
                              throws TarantoolClientException

Description copied from interface: TarantoolCallOperations

Execute a function defined on Tarantool instance. The call result is interpreted as an array of tuples.

Specified by:

call in interface TarantoolCallOperations

Type Parameters:

T - desired function call result type

Parameters:

functionName - function name, must not be null or empty

arguments - list of function arguments. The object mapper specified in the client configuration will be used for arguments conversion to MessagePack entities

resultMapperSupplier - mapper supplier for result value MessagePack entity-to-object conversion

Returns:

some result

Throws:

TarantoolClientException - if the client is not connected or some other error occurred

callForTupleResult

public <T> CompletableFuture<TarantoolResult<T>> callForTupleResult(String functionName,
                                                                    Collection<?> arguments,
                                                                    Supplier<? extends MessagePackObjectMapper> argumentsMapperSupplier,
                                                                    Class<T> tupleClass)
                                                             throws TarantoolClientException

Description copied from interface: TarantoolCallOperations

Execute a function defined on Tarantool instance. The call result is interpreted as an array of tuples. The value mapper specified in the client configuration will be used for converting the result values from MessagePack arrays to the specified entity type.

Specified by:

callForTupleResult in interface TarantoolCallOperations

Type Parameters:

T - desired function call result type

Parameters:

functionName - function name, must not be null or empty

arguments - list of function arguments

argumentsMapperSupplier - mapper supplier for arguments object-to-MessagePack entity conversion

tupleClass - target result entity class

Returns:

some result

Throws:

TarantoolClientException - if the client is not connected or some other error occurred

call

public <T> CompletableFuture<T> call(String functionName,
                                     Collection<?> arguments,
                                     Supplier<? extends MessagePackObjectMapper> argumentsMapperSupplier,
                                     Supplier<CallResultMapper<T,SingleValueCallResult<T>>> resultMapperSupplier)
                              throws TarantoolClientException

Description copied from interface: TarantoolCallOperations

Execute a function defined on Tarantool instance. The call result is interpreted as an array of tuples.

Specified by:

call in interface TarantoolCallOperations

Type Parameters:

T - desired function call result type

Parameters:

functionName - function name, must not be null or empty

arguments - list of function arguments

argumentsMapperSupplier - mapper supplier for arguments object-to-MessagePack entity conversion

resultMapperSupplier - mapper supplier for result value MessagePack entity-to-object conversion

Returns:

some result

Throws:

TarantoolClientException - if the client is not connected or some other error occurred

callForSingleResult

public <S> CompletableFuture<S> callForSingleResult(String functionName,
                                                    Collection<?> arguments,
                                                    Class<S> resultClass)
                                             throws TarantoolClientException

Description copied from interface: TarantoolCallOperations

Execute a function defined on Tarantool instance. The first item of the call result will be interpreted as a value, and the second -- as an error

Specified by:

callForSingleResult in interface TarantoolCallOperations

Type Parameters:

S - target result content type

Parameters:

functionName - function name, must not be null or empty

arguments - list of function arguments

resultClass - target result entity class

Returns:

some result

Throws:

TarantoolClientException - if the client is not connected or some other error occurred

callForSingleResult

public <S> CompletableFuture<S> callForSingleResult(String functionName,
                                                    Collection<?> arguments,
                                                    ValueConverter<org.msgpack.value.Value,S> valueConverter)
                                             throws TarantoolClientException

Description copied from interface: TarantoolCallOperations

Execute a function defined on Tarantool instance. The first item of the call result will be interpreted as a value, and the second -- as an error

Specified by:

callForSingleResult in interface TarantoolCallOperations

Type Parameters:

S - target result content type

Parameters:

functionName - function name, must not be null or empty

arguments - list of function arguments

valueConverter - MessagePack value to entity converter for each result item

Returns:

some result

Throws:

TarantoolClientException - if the client is not connected or some other error occurred

callForSingleResult

public <S> CompletableFuture<S> callForSingleResult(String functionName,
                                                    Collection<?> arguments,
                                                    Supplier<CallResultMapper<S,SingleValueCallResult<S>>> resultMapperSupplier)
                                             throws TarantoolClientException

Description copied from interface: TarantoolCallOperations

Execute a function defined on Tarantool instance. The first item of the call result will be interpreted as a value, and the second -- as an error

Specified by:

callForSingleResult in interface TarantoolCallOperations

Type Parameters:

S - target result content type

Parameters:

functionName - function name, must not be null or empty

arguments - list of function arguments

resultMapperSupplier - mapper supplier for result value MessagePack entity-to-object conversion

Returns:

some result

Throws:

TarantoolClientException - if the client is not connected or some other error occurred

callForSingleResult

public <S> CompletableFuture<S> callForSingleResult(String functionName,
                                                    Class<S> resultClass)
                                             throws TarantoolClientException

Description copied from interface: TarantoolCallOperations

Execute a function defined on Tarantool instance. The first item of the call result will be interpreted as a value, and the second -- as an error

Specified by:

callForSingleResult in interface TarantoolCallOperations

Type Parameters:

S - target result content type

Parameters:

functionName - function name, must not be null or empty

resultClass - target result entity class

Returns:

some result

Throws:

TarantoolClientException - if the client is not connected or some other error occurred

callForSingleResult

public <S> CompletableFuture<S> callForSingleResult(String functionName,
                                                    ValueConverter<org.msgpack.value.Value,S> valueConverter)
                                             throws TarantoolClientException

Description copied from interface: TarantoolCallOperations

Execute a function defined on Tarantool instance. The first item of the call result will be interpreted as a value, and the second -- as an error

Specified by:

callForSingleResult in interface TarantoolCallOperations

Type Parameters:

S - target result content type

Parameters:

functionName - function name, must not be null or empty

valueConverter - MessagePack value to entity converter for each result item

Returns:

some result

Throws:

TarantoolClientException - if the client is not connected or some other error occurred

callForSingleResult

public <S> CompletableFuture<S> callForSingleResult(String functionName,
                                                    Supplier<CallResultMapper<S,SingleValueCallResult<S>>> resultMapperSupplier)
                                             throws TarantoolClientException

Description copied from interface: TarantoolCallOperations

Execute a function defined on Tarantool instance. The first item of the call result will be interpreted as a value, and the second -- as an error

Specified by:

callForSingleResult in interface TarantoolCallOperations

Type Parameters:

S - target result content type

Parameters:

functionName - function name, must not be null or empty

resultMapperSupplier - mapper supplier for result value MessagePack entity-to-object conversion

Returns:

some result

Throws:

TarantoolClientException - if the client is not connected or some other error occurred

callForSingleResult

public <S> CompletableFuture<S> callForSingleResult(String functionName,
                                                    Collection<?> arguments,
                                                    Supplier<? extends MessagePackObjectMapper> argumentsMapperSupplier,
                                                    Class<S> resultClass)
                                             throws TarantoolClientException

Description copied from interface: TarantoolCallOperations

Execute a function defined on Tarantool instance. The first item of the call result will be interpreted as a value, and the second -- as an error

Specified by:

callForSingleResult in interface TarantoolCallOperations

Type Parameters:

S - target result content type

Parameters:

functionName - function name, must not be null or empty

arguments - list of function arguments

argumentsMapperSupplier - mapper supplier for arguments object-to-MessagePack entity conversion

resultClass - target result entity class

Returns:

some result

Throws:

TarantoolClientException - if the client is not connected or some other error occurred

callForSingleResult

public <S> CompletableFuture<S> callForSingleResult(String functionName,
                                                    Collection<?> arguments,
                                                    Supplier<? extends MessagePackObjectMapper> argumentsMapperSupplier,
                                                    ValueConverter<org.msgpack.value.Value,S> valueConverter)
                                             throws TarantoolClientException

Description copied from interface: TarantoolCallOperations

Execute a function defined on Tarantool instance. The first item of the call result will be interpreted as a value, and the second -- as an error

Specified by:

callForSingleResult in interface TarantoolCallOperations

Type Parameters:

S - target result content type

Parameters:

functionName - function name, must not be null or empty

arguments - list of function arguments

argumentsMapperSupplier - mapper supplier for arguments object-to-MessagePack entity conversion

valueConverter - MessagePack value to entity converter for each result item

Returns:

some result

Throws:

TarantoolClientException - if the client is not connected or some other error occurred

callForSingleResult

public <S> CompletableFuture<S> callForSingleResult(String functionName,
                                                    Collection<?> arguments,
                                                    Supplier<? extends MessagePackObjectMapper> argumentsMapperSupplier,
                                                    Supplier<CallResultMapper<S,SingleValueCallResult<S>>> resultMapperSupplier)
                                             throws TarantoolClientException

Description copied from interface: TarantoolCallOperations

Execute a function defined on Tarantool instance. The first item of the call result will be interpreted as a value, and the second -- as an error

Specified by:

callForSingleResult in interface TarantoolCallOperations

Type Parameters:

S - target result content type

Parameters:

functionName - function name, must not be null or empty

arguments - list of function arguments

argumentsMapperSupplier - mapper supplier for arguments object-to-MessagePack entity conversion

resultMapperSupplier - mapper supplier for result value MessagePack entity-to-object conversion

Returns:

some result

Throws:

TarantoolClientException - if the client is not connected or some other error occurred

callForMultiResult

public <T,R extends List<T>> CompletableFuture<R> callForMultiResult(String functionName,
                                                                     Collection<?> arguments,
                                                                     Supplier<R> resultContainerSupplier,
                                                                     Class<T> resultClass)
                                                              throws TarantoolClientException

Description copied from interface: TarantoolCallOperations

Execute a function defined on Tarantool instance. All multi-return result items will be put into a list

Specified by:

callForMultiResult in interface TarantoolCallOperations

Type Parameters:

T - target result content type

R - target result type

Parameters:

functionName - function name, must not be null or empty

arguments - list of function arguments

resultContainerSupplier - supplier function for new empty result collection

resultClass - target result entity class

Returns:

some result

Throws:

TarantoolClientException - if the client is not connected or some other error occurred

callForMultiResult

public <T,R extends List<T>> CompletableFuture<R> callForMultiResult(String functionName,
                                                                     Collection<?> arguments,
                                                                     Supplier<R> resultContainerSupplier,
                                                                     ValueConverter<org.msgpack.value.Value,T> valueConverter)
                                                              throws TarantoolClientException

Description copied from interface: TarantoolCallOperations

Execute a function defined on Tarantool instance. All multi-return result items will be put into a list

Specified by:

callForMultiResult in interface TarantoolCallOperations

Type Parameters:

T - target result content type

R - target result type

Parameters:

functionName - function name, must not be null or empty

arguments - list of function arguments

resultContainerSupplier - supplier function for new empty result collection

valueConverter - MessagePack value to entity converter for each result item

Returns:

some result

Throws:

TarantoolClientException - if the client is not connected or some other error occurred

callForMultiResult

public <T,R extends List<T>> CompletableFuture<R> callForMultiResult(String functionName,
                                                                     Collection<?> arguments,
                                                                     Supplier<CallResultMapper<R,MultiValueCallResult<T,R>>> resultMapperSupplier)
                                                              throws TarantoolClientException

Description copied from interface: TarantoolCallOperations

Execute a function defined on Tarantool instance. All multi-return result items will be put into a list

Specified by:

callForMultiResult in interface TarantoolCallOperations

Type Parameters:

T - target result content type

R - target result type

Parameters:

functionName - function name, must not be null or empty

arguments - list of function arguments

resultMapperSupplier - mapper supplier for result value MessagePack entity-to-object conversion

Returns:

some result

Throws:

TarantoolClientException - if the client is not connected or some other error occurred

callForMultiResult

public <T,R extends List<T>> CompletableFuture<R> callForMultiResult(String functionName,
                                                                     Supplier<R> resultContainerSupplier,
                                                                     Class<T> resultClass)
                                                              throws TarantoolClientException

Description copied from interface: TarantoolCallOperations

Execute a function defined on Tarantool instance. All multi-return result items will be put into a list

Specified by:

callForMultiResult in interface TarantoolCallOperations

Type Parameters:

T - target result content type

R - target result type

Parameters:

functionName - function name, must not be null or empty

resultContainerSupplier - supplier function for new empty result collection

resultClass - target result entity class

Returns:

some result

Throws:

TarantoolClientException - if the client is not connected or some other error occurred

callForMultiResult

public <T,R extends List<T>> CompletableFuture<R> callForMultiResult(String functionName,
                                                                     Supplier<R> resultContainerSupplier,
                                                                     ValueConverter<org.msgpack.value.Value,T> valueConverter)
                                                              throws TarantoolClientException

Description copied from interface: TarantoolCallOperations

Execute a function defined on Tarantool instance. All multi-return result items will be put into a list

Specified by:

callForMultiResult in interface TarantoolCallOperations

Type Parameters:

T - target result content type

R - target result type

Parameters:

functionName - function name, must not be null or empty

resultContainerSupplier - supplier function for new empty result collection

valueConverter - MessagePack value to entity converter for each result item

Returns:

some result

Throws:

TarantoolClientException - if the client is not connected or some other error occurred

callForMultiResult

public <T,R extends List<T>> CompletableFuture<R> callForMultiResult(String functionName,
                                                                     Supplier<CallResultMapper<R,MultiValueCallResult<T,R>>> resultMapperSupplier)
                                                              throws TarantoolClientException

Description copied from interface: TarantoolCallOperations

Execute a function defined on Tarantool instance. All multi-return result items will be put into a list

Specified by:

callForMultiResult in interface TarantoolCallOperations

Type Parameters:

T - target result content type

R - target result type

Parameters:

functionName - function name, must not be null or empty

resultMapperSupplier - mapper supplier for result value MessagePack entity-to-object conversion

Returns:

some result

Throws:

TarantoolClientException - if the client is not connected or some other error occurred

callForMultiResult

public <T,R extends List<T>> CompletableFuture<R> callForMultiResult(String functionName,
                                                                     Collection<?> arguments,
                                                                     Supplier<? extends MessagePackObjectMapper> argumentsMapperSupplier,
                                                                     Supplier<R> resultContainerSupplier,
                                                                     Class<T> resultClass)
                                                              throws TarantoolClientException

Description copied from interface: TarantoolCallOperations

Execute a function defined on Tarantool instance. All multi-return result items will be put into a list

Specified by:

callForMultiResult in interface TarantoolCallOperations

Type Parameters:

T - target result content type

R - target result type

Parameters:

functionName - function name, must not be null or empty

arguments - list of function arguments

argumentsMapperSupplier - mapper supplier for arguments object-to-MessagePack entity conversion

resultContainerSupplier - supplier function for new empty result collection

resultClass - target result entity class

Returns:

some result

Throws:

TarantoolClientException - if the client is not connected or some other error occurred

callForMultiResult

public <T,R extends List<T>> CompletableFuture<R> callForMultiResult(String functionName,
                                                                     Collection<?> arguments,
                                                                     Supplier<? extends MessagePackObjectMapper> argumentsMapperSupplier,
                                                                     Supplier<R> resultContainerSupplier,
                                                                     ValueConverter<org.msgpack.value.Value,T> valueConverter)
                                                              throws TarantoolClientException

Description copied from interface: TarantoolCallOperations

Execute a function defined on Tarantool instance. All multi-return result items will be put into a list

Specified by:

callForMultiResult in interface TarantoolCallOperations

Type Parameters:

T - target result content type

R - target result type

Parameters:

functionName - function name, must not be null or empty

arguments - list of function arguments

argumentsMapperSupplier - mapper supplier for arguments object-to-MessagePack entity conversion

resultContainerSupplier - supplier function for new empty result collection

valueConverter - MessagePack value to entity converter for each result item

Returns:

some result

Throws:

TarantoolClientException - if the client is not connected or some other error occurred

callForMultiResult

public <T,R extends List<T>> CompletableFuture<R> callForMultiResult(String functionName,
                                                                     Collection<?> arguments,
                                                                     Supplier<? extends MessagePackObjectMapper> argumentsMapperSupplier,
                                                                     Supplier<CallResultMapper<R,MultiValueCallResult<T,R>>> resultMapperSupplier)
                                                              throws TarantoolClientException

Description copied from interface: TarantoolCallOperations

Execute a function defined on Tarantool instance. All multi-return result items will be put into a list

Specified by:

callForMultiResult in interface TarantoolCallOperations

Type Parameters:

T - target result content type

R - target result type

Parameters:

functionName - function name, must not be null or empty

arguments - list of function arguments

argumentsMapperSupplier - mapper supplier for arguments object-to-MessagePack entity conversion

resultMapperSupplier - mapper supplier for result value MessagePack entity-to-object conversion

Returns:

some result

Throws:

TarantoolClientException - if the client is not connected or some other error occurred

eval

public CompletableFuture<List<?>> eval(String expression)
                                throws TarantoolClientException

Description copied from interface: TarantoolEvalOperations

Execute a Lua expression in the Tarantool instance. If a result is expected, the expression must start with keyword return. The value mapper specified in the client configuration will be used for converting the result values from MessagePack entities to objects.

Specified by:

eval in interface TarantoolEvalOperations

Parameters:

expression - lua expression, must not be null or empty

Returns:

some result

Throws:

TarantoolClientException - if the client is not connected

eval

public CompletableFuture<List<?>> eval(String expression,
                                       Collection<?> arguments)
                                throws TarantoolClientException

Description copied from interface: TarantoolEvalOperations

Execute a Lua expression in the Tarantool instance. If a result is expected, the expression must start with keyword return. The value mapper specified in the client configuration will be used for converting the result values from MessagePack entities to objects.

Specified by:

eval in interface TarantoolEvalOperations

Parameters:

expression - lua expression, must not be null or empty

arguments - the list of function arguments. The object mapper specified in the client configuration will be used for arguments conversion to MessagePack entities

Returns:

some result

Throws:

TarantoolClientException - if the client is not connected

eval

public CompletableFuture<List<?>> eval(String expression,
                                       Supplier<? extends MessagePackValueMapper> resultMapperSupplier)
                                throws TarantoolClientException

Description copied from interface: TarantoolEvalOperations

Execute a Lua expression in the Tarantool instance. If a result is expected, the expression must start with keyword return.

Specified by:

eval in interface TarantoolEvalOperations

Parameters:

expression - lua expression, must not be null or empty

resultMapperSupplier - mapper supplier for result value MessagePack entity-to-object conversion

Returns:

some result

Throws:

TarantoolClientException - if the client is not connected

eval

public CompletableFuture<List<?>> eval(String expression,
                                       Collection<?> arguments,
                                       Supplier<? extends MessagePackValueMapper> resultMapperSupplier)
                                throws TarantoolClientException

Description copied from interface: TarantoolEvalOperations

Execute a Lua expression in the Tarantool instance. If a result is expected, the expression must start with keyword return.

Specified by:

eval in interface TarantoolEvalOperations

Parameters:

expression - lua expression, must not be null or empty

arguments - the list of function arguments. The object mapper specified in the client configuration will be used for arguments conversion to MessagePack entities

resultMapperSupplier - mapper supplier for result value MessagePack entity-to-object conversion

Returns:

some result

Throws:

TarantoolClientException - if the client is not connected

eval

public CompletableFuture<List<?>> eval(String expression,
                                       Collection<?> arguments,
                                       Supplier<? extends MessagePackObjectMapper> argumentsMapperSupplier,
                                       Supplier<? extends MessagePackValueMapper> resultMapperSupplier)
                                throws TarantoolClientException

Description copied from interface: TarantoolEvalOperations

Execute a Lua expression in the Tarantool instance. If a result is expected, the expression must start with keyword return.

Specified by:

eval in interface TarantoolEvalOperations

Parameters:

expression - lua expression, must not be null or empty

arguments - the list of function arguments

argumentsMapperSupplier - mapper supplier for arguments object-to-MessagePack entity conversion

resultMapperSupplier - mapper supplier for result value MessagePack entity-to-object conversion

Returns:

some result

Throws:

TarantoolClientException - if the client is not connected

getConfig

public TarantoolClientConfig getConfig()

Description copied from interface: TarantoolClient

Get the Tarantool client config passed to this client

Specified by:

getConfig in interface TarantoolClient<T extends Packable,R extends Collection<T>>

Returns:

TarantoolClientConfig instance

getBootstrap

protected io.netty.bootstrap.Bootstrap getBootstrap()

close

public void close()
           throws Exception

Specified by:

close in interface AutoCloseable

Throws:

Exception

getConnectionListeners

public TarantoolConnectionListeners getConnectionListeners()

Description copied from interface: TarantoolClient

Get collection of connection listeners. Used for adding new listeners, removing listeners or examining the collection

Specified by:

getConnectionListeners in interface TarantoolClient<T extends Packable,R extends Collection<T>>

Returns:

connection listeners

getResultMapperFactoryFactory

public ResultMapperFactoryFactory getResultMapperFactoryFactory()

Description copied from interface: TarantoolCallOperations

Get the default factory for result mapper factory instances

Specified by:

getResultMapperFactoryFactory in interface TarantoolCallOperations

Returns:

result mapper factory instances factory instance