org.tarantool

Class TarantoolClientImpl

java.lang.Object

org.tarantool.AbstractTarantoolOps<Integer,List<?>,Object,Result>

org.tarantool.TarantoolBase<Future<List<?>>>

org.tarantool.TarantoolClientImpl

All Implemented Interfaces:

TarantoolClient, TarantoolClientOps<Integer,List<?>,Object,Future<List<?>>>

public class TarantoolClientImpl
extends TarantoolBase<Future<List<?>>>
implements TarantoolClient

Field Summary

Fields

Modifier and Type	Field and Description
static CommunicationException	NOT_INIT_EXCEPTION

Constructor Summary

Constructors

Constructor and Description
TarantoolClientImpl(SocketChannelProvider socketProvider, TarantoolClientConfig config)

Method Summary

Modifier and Type	Method and Description
TarantoolClientOps<Integer,List<?>,Object,Future<List<?>>>	asyncOps()
void	close()
Future<List<?>>	exec(Code code, Object... args)
TarantoolClientOps<Integer,List<?>,Object,Long>	fireAndForgetOps()
TarantoolClientStats	getStats()
Exception	getThumbstone()
boolean	isAlive()
void	ping()
TarantoolClientOps<Integer,List<?>,Object,List<?>>	syncOps()
void	waitAlive()
boolean	waitAlive(long timeout, TimeUnit unit)

Methods inherited from class org.tarantool.TarantoolBase

setInitialRequestSize

Methods inherited from class org.tarantool.AbstractTarantoolOps

call, delete, eval, insert, replace, select, setCallCode, update, upsert

Methods inherited from class java.lang.Object

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

Field Detail

NOT_INIT_EXCEPTION

public static final CommunicationException NOT_INIT_EXCEPTION

Constructor Detail

TarantoolClientImpl

public TarantoolClientImpl(SocketChannelProvider socketProvider,
                           TarantoolClientConfig config)

Method Detail

exec

public Future<List<?>> exec(Code code,
                            Object... args)

Specified by:

exec in class AbstractTarantoolOps<Integer,List<?>,Object,Future<List<?>>>

ping

public void ping()

Specified by:

ping in interface TarantoolClientOps<Integer,List<?>,Object,Future<List<?>>>

Overrides:

ping in class AbstractTarantoolOps<Integer,List<?>,Object,Future<List<?>>>

close

public void close()

Specified by:

close in interface TarantoolClient

Specified by:

close in interface TarantoolClientOps<Integer,List<?>,Object,Future<List<?>>>

isAlive

public boolean isAlive()

Specified by:

isAlive in interface TarantoolClient

waitAlive

public void waitAlive()
               throws InterruptedException

Specified by:

waitAlive in interface TarantoolClient

Throws:

InterruptedException

waitAlive

public boolean waitAlive(long timeout,
                         TimeUnit unit)
                  throws InterruptedException

Specified by:

waitAlive in interface TarantoolClient

Throws:

InterruptedException

syncOps

public TarantoolClientOps<Integer,List<?>,Object,List<?>> syncOps()

Specified by:

syncOps in interface TarantoolClient

asyncOps

public TarantoolClientOps<Integer,List<?>,Object,Future<List<?>>> asyncOps()

Specified by:

asyncOps in interface TarantoolClient

fireAndForgetOps

public TarantoolClientOps<Integer,List<?>,Object,Long> fireAndForgetOps()

Specified by:

fireAndForgetOps in interface TarantoolClient

getThumbstone

public Exception getThumbstone()

getStats

public TarantoolClientStats getStats()