Package io.tarantool.driver.core

Class RetryingTarantoolTupleClient

java.lang.Object

io.tarantool.driver.core.RetryingTarantoolClient<TarantoolTuple,TarantoolResult<TarantoolTuple>>

io.tarantool.driver.core.RetryingTarantoolTupleClient

All Implemented Interfaces:

TarantoolCallOperations, TarantoolClient<TarantoolTuple,TarantoolResult<TarantoolTuple>>, TarantoolEvalOperations, AutoCloseable

public class RetryingTarantoolTupleClient
extends RetryingTarantoolClient<TarantoolTuple,TarantoolResult<TarantoolTuple>>

RetryingTarantoolClient implementation for working with default tuples

Constructor Summary

Constructors

Constructor	Description
RetryingTarantoolTupleClient(TarantoolClient<TarantoolTuple,TarantoolResult<TarantoolTuple>> decoratedClient, RequestRetryPolicyFactory retryPolicyFactory)	Basic constructor
RetryingTarantoolTupleClient(TarantoolClient<TarantoolTuple,TarantoolResult<TarantoolTuple>> decoratedClient, RequestRetryPolicyFactory retryPolicyFactory, Executor executor)	Basic constructor

Method Summary

Modifier and Type	Method	Description
protected RetryingTarantoolSpace<TarantoolTuple,TarantoolResult<TarantoolTuple>>	spaceOperations(TarantoolSpaceOperations<TarantoolTuple,TarantoolResult<TarantoolTuple>> decoratedSpaceOperations, RequestRetryPolicyFactory retryPolicyFactory, Executor executor)	Creates a space API implementation instance for the specified space

Methods inherited from class io.tarantool.driver.core.RetryingTarantoolClient

call, call, call, call, call, call, call, call, call, call, callForMultiResult, callForMultiResult, callForMultiResult, callForMultiResult, callForMultiResult, callForMultiResult, callForMultiResult, callForMultiResult, callForMultiResult, callForSingleResult, callForSingleResult, callForSingleResult, callForSingleResult, callForSingleResult, callForSingleResult, callForSingleResult, callForSingleResult, callForSingleResult, close, eval, eval, eval, eval, eval, getClient, getConfig, getConnectionListeners, getResultMapperFactoryFactory, getRetryPolicyFactory, getVersion, metadata, metadataProvider, refresh, space, space

Methods inherited from class java.lang.Object

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

Constructor Detail

RetryingTarantoolTupleClient

public RetryingTarantoolTupleClient(TarantoolClient<TarantoolTuple,TarantoolResult<TarantoolTuple>> decoratedClient,
                                    RequestRetryPolicyFactory retryPolicyFactory)

Basic constructor

Parameters:

decoratedClient - configured Tarantool client

retryPolicyFactory - request retrying policy settings

RetryingTarantoolTupleClient

public RetryingTarantoolTupleClient(TarantoolClient<TarantoolTuple,TarantoolResult<TarantoolTuple>> decoratedClient,
                                    RequestRetryPolicyFactory retryPolicyFactory,
                                    Executor executor)

Basic constructor

Parameters:

decoratedClient - configured Tarantool client

retryPolicyFactory - request retrying policy settings

executor - executor service for retry callbacks

Method Detail

spaceOperations

protected RetryingTarantoolSpace<TarantoolTuple,TarantoolResult<TarantoolTuple>> spaceOperations(TarantoolSpaceOperations<TarantoolTuple,TarantoolResult<TarantoolTuple>> decoratedSpaceOperations,
                                                                                                       RequestRetryPolicyFactory retryPolicyFactory,
                                                                                                       Executor executor)

Description copied from class: RetryingTarantoolClient

Creates a space API implementation instance for the specified space

Specified by:

spaceOperations in class RetryingTarantoolClient<TarantoolTuple,TarantoolResult<TarantoolTuple>>

Parameters:

decoratedSpaceOperations - space API implementation form the decorated Tarantool client instance

retryPolicyFactory - request retrying policy factory

executor - executor service for retry callbacks

Returns:

space API implementation instance