org.apache.tephra.distributed.thrift

Class TTransactionServer.AsyncClient

java.lang.Object

org.apache.thrift.async.TAsyncClient

org.apache.tephra.distributed.thrift.TTransactionServer.AsyncClient

All Implemented Interfaces:

TTransactionServer.AsyncIface

Enclosing class:

TTransactionServer

public static class TTransactionServer.AsyncClient
extends org.apache.thrift.async.TAsyncClient
implements TTransactionServer.AsyncIface

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	TTransactionServer.AsyncClient.abortTx_call
static class	TTransactionServer.AsyncClient.canCommitOrThrow_call
static class	TTransactionServer.AsyncClient.canCommitTx_call
static class	TTransactionServer.AsyncClient.checkpoint_call
static class	TTransactionServer.AsyncClient.commitOrThrow_call
static class	TTransactionServer.AsyncClient.commitTx_call
static class	TTransactionServer.AsyncClient.Factory
static class	TTransactionServer.AsyncClient.getSnapshot_call
static class	TTransactionServer.AsyncClient.invalidateTx_call
static class	TTransactionServer.AsyncClient.invalidTxSize_call
static class	TTransactionServer.AsyncClient.pruneNow_call
static class	TTransactionServer.AsyncClient.resetState_call
static class	TTransactionServer.AsyncClient.startLong_call
static class	TTransactionServer.AsyncClient.startLongClientId_call
static class	TTransactionServer.AsyncClient.startShort_call
static class	TTransactionServer.AsyncClient.startShortClientId_call
static class	TTransactionServer.AsyncClient.startShortTimeout_call
static class	TTransactionServer.AsyncClient.startShortWithClientIdAndTimeOut_call
static class	TTransactionServer.AsyncClient.startShortWithTimeout_call
static class	TTransactionServer.AsyncClient.status_call
static class	TTransactionServer.AsyncClient.truncateInvalidTx_call
static class	TTransactionServer.AsyncClient.truncateInvalidTxBefore_call

Field Summary

Fields inherited from class org.apache.thrift.async.TAsyncClient

___currentMethod, ___manager, ___protocolFactory, ___transport

Constructor Summary

Constructors

Constructor and Description
AsyncClient(org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.async.TAsyncClientManager clientManager, org.apache.thrift.transport.TNonblockingTransport transport)

Method Summary

Modifier and Type	Method and Description
void	abortTx(TTransaction tx, org.apache.thrift.async.AsyncMethodCallback<TTransactionServer.AsyncClient.abortTx_call> resultHandler)
void	canCommitOrThrow(long tx, Set<ByteBuffer> changes, org.apache.thrift.async.AsyncMethodCallback<TTransactionServer.AsyncClient.canCommitOrThrow_call> resultHandler)
void	canCommitTx(TTransaction tx, Set<ByteBuffer> changes, org.apache.thrift.async.AsyncMethodCallback<TTransactionServer.AsyncClient.canCommitTx_call> resultHandler)
void	checkpoint(TTransaction tx, org.apache.thrift.async.AsyncMethodCallback<TTransactionServer.AsyncClient.checkpoint_call> resultHandler)
void	commitOrThrow(long txId, long wp, org.apache.thrift.async.AsyncMethodCallback<TTransactionServer.AsyncClient.commitOrThrow_call> resultHandler)
void	commitTx(TTransaction tx, org.apache.thrift.async.AsyncMethodCallback<TTransactionServer.AsyncClient.commitTx_call> resultHandler)
void	getSnapshot(org.apache.thrift.async.AsyncMethodCallback<TTransactionServer.AsyncClient.getSnapshot_call> resultHandler)
void	invalidateTx(long txid, org.apache.thrift.async.AsyncMethodCallback<TTransactionServer.AsyncClient.invalidateTx_call> resultHandler)
void	invalidTxSize(org.apache.thrift.async.AsyncMethodCallback<TTransactionServer.AsyncClient.invalidTxSize_call> resultHandler)
void	pruneNow(org.apache.thrift.async.AsyncMethodCallback<TTransactionServer.AsyncClient.pruneNow_call> resultHandler)
void	resetState(org.apache.thrift.async.AsyncMethodCallback<TTransactionServer.AsyncClient.resetState_call> resultHandler)
void	startLong(org.apache.thrift.async.AsyncMethodCallback<TTransactionServer.AsyncClient.startLong_call> resultHandler)
void	startLongClientId(String clientId, org.apache.thrift.async.AsyncMethodCallback<TTransactionServer.AsyncClient.startLongClientId_call> resultHandler)
void	startShort(org.apache.thrift.async.AsyncMethodCallback<TTransactionServer.AsyncClient.startShort_call> resultHandler)
void	startShortClientId(String clientId, org.apache.thrift.async.AsyncMethodCallback<TTransactionServer.AsyncClient.startShortClientId_call> resultHandler)
void	startShortTimeout(int timeout, org.apache.thrift.async.AsyncMethodCallback<TTransactionServer.AsyncClient.startShortTimeout_call> resultHandler)
void	startShortWithClientIdAndTimeOut(String clientId, int timeout, org.apache.thrift.async.AsyncMethodCallback<TTransactionServer.AsyncClient.startShortWithClientIdAndTimeOut_call> resultHandler)
void	startShortWithTimeout(int timeout, org.apache.thrift.async.AsyncMethodCallback<TTransactionServer.AsyncClient.startShortWithTimeout_call> resultHandler)
void	status(org.apache.thrift.async.AsyncMethodCallback<TTransactionServer.AsyncClient.status_call> resultHandler)
void	truncateInvalidTx(Set<Long> txns, org.apache.thrift.async.AsyncMethodCallback<TTransactionServer.AsyncClient.truncateInvalidTx_call> resultHandler)
void	truncateInvalidTxBefore(long time, org.apache.thrift.async.AsyncMethodCallback<TTransactionServer.AsyncClient.truncateInvalidTxBefore_call> resultHandler)

Methods inherited from class org.apache.thrift.async.TAsyncClient

checkReady, getError, getProtocolFactory, getTimeout, hasError, hasTimeout, onComplete, onError, setTimeout

Methods inherited from class java.lang.Object

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

Constructor Detail

AsyncClient

public AsyncClient(org.apache.thrift.protocol.TProtocolFactory protocolFactory,
                   org.apache.thrift.async.TAsyncClientManager clientManager,
                   org.apache.thrift.transport.TNonblockingTransport transport)

Method Detail

startLong

public void startLong(org.apache.thrift.async.AsyncMethodCallback<TTransactionServer.AsyncClient.startLong_call> resultHandler)
               throws org.apache.thrift.TException

Specified by:

startLong in interface TTransactionServer.AsyncIface

Throws:

org.apache.thrift.TException

startShort

public void startShort(org.apache.thrift.async.AsyncMethodCallback<TTransactionServer.AsyncClient.startShort_call> resultHandler)
                throws org.apache.thrift.TException

Specified by:

startShort in interface TTransactionServer.AsyncIface

Throws:

org.apache.thrift.TException

startLongClientId

public void startLongClientId(String clientId,
                              org.apache.thrift.async.AsyncMethodCallback<TTransactionServer.AsyncClient.startLongClientId_call> resultHandler)
                       throws org.apache.thrift.TException

Specified by:

startLongClientId in interface TTransactionServer.AsyncIface

Throws:

org.apache.thrift.TException

startShortTimeout

public void startShortTimeout(int timeout,
                              org.apache.thrift.async.AsyncMethodCallback<TTransactionServer.AsyncClient.startShortTimeout_call> resultHandler)
                       throws org.apache.thrift.TException

Specified by:

startShortTimeout in interface TTransactionServer.AsyncIface

Throws:

org.apache.thrift.TException

startShortClientId

public void startShortClientId(String clientId,
                               org.apache.thrift.async.AsyncMethodCallback<TTransactionServer.AsyncClient.startShortClientId_call> resultHandler)
                        throws org.apache.thrift.TException

Specified by:

startShortClientId in interface TTransactionServer.AsyncIface

Throws:

org.apache.thrift.TException

startShortWithClientIdAndTimeOut

public void startShortWithClientIdAndTimeOut(String clientId,
                                             int timeout,
                                             org.apache.thrift.async.AsyncMethodCallback<TTransactionServer.AsyncClient.startShortWithClientIdAndTimeOut_call> resultHandler)
                                      throws org.apache.thrift.TException

Specified by:

startShortWithClientIdAndTimeOut in interface TTransactionServer.AsyncIface

Throws:

org.apache.thrift.TException

startShortWithTimeout

public void startShortWithTimeout(int timeout,
                                  org.apache.thrift.async.AsyncMethodCallback<TTransactionServer.AsyncClient.startShortWithTimeout_call> resultHandler)
                           throws org.apache.thrift.TException

Specified by:

startShortWithTimeout in interface TTransactionServer.AsyncIface

Throws:

org.apache.thrift.TException

canCommitTx

public void canCommitTx(TTransaction tx,
                        Set<ByteBuffer> changes,
                        org.apache.thrift.async.AsyncMethodCallback<TTransactionServer.AsyncClient.canCommitTx_call> resultHandler)
                 throws org.apache.thrift.TException

Specified by:

canCommitTx in interface TTransactionServer.AsyncIface

Throws:

org.apache.thrift.TException

canCommitOrThrow

public void canCommitOrThrow(long tx,
                             Set<ByteBuffer> changes,
                             org.apache.thrift.async.AsyncMethodCallback<TTransactionServer.AsyncClient.canCommitOrThrow_call> resultHandler)
                      throws org.apache.thrift.TException

Specified by:

canCommitOrThrow in interface TTransactionServer.AsyncIface

Throws:

org.apache.thrift.TException

commitTx

public void commitTx(TTransaction tx,
                     org.apache.thrift.async.AsyncMethodCallback<TTransactionServer.AsyncClient.commitTx_call> resultHandler)
              throws org.apache.thrift.TException

Specified by:

commitTx in interface TTransactionServer.AsyncIface

Throws:

org.apache.thrift.TException

commitOrThrow

public void commitOrThrow(long txId,
                          long wp,
                          org.apache.thrift.async.AsyncMethodCallback<TTransactionServer.AsyncClient.commitOrThrow_call> resultHandler)
                   throws org.apache.thrift.TException

Specified by:

commitOrThrow in interface TTransactionServer.AsyncIface

Throws:

org.apache.thrift.TException

abortTx

public void abortTx(TTransaction tx,
                    org.apache.thrift.async.AsyncMethodCallback<TTransactionServer.AsyncClient.abortTx_call> resultHandler)
             throws org.apache.thrift.TException

Specified by:

abortTx in interface TTransactionServer.AsyncIface

Throws:

org.apache.thrift.TException

invalidateTx

public void invalidateTx(long txid,
                         org.apache.thrift.async.AsyncMethodCallback<TTransactionServer.AsyncClient.invalidateTx_call> resultHandler)
                  throws org.apache.thrift.TException

Specified by:

invalidateTx in interface TTransactionServer.AsyncIface

Throws:

org.apache.thrift.TException

getSnapshot

public void getSnapshot(org.apache.thrift.async.AsyncMethodCallback<TTransactionServer.AsyncClient.getSnapshot_call> resultHandler)
                 throws org.apache.thrift.TException

Specified by:

getSnapshot in interface TTransactionServer.AsyncIface

Throws:

org.apache.thrift.TException

resetState

public void resetState(org.apache.thrift.async.AsyncMethodCallback<TTransactionServer.AsyncClient.resetState_call> resultHandler)
                throws org.apache.thrift.TException

Specified by:

resetState in interface TTransactionServer.AsyncIface

Throws:

org.apache.thrift.TException

status

public void status(org.apache.thrift.async.AsyncMethodCallback<TTransactionServer.AsyncClient.status_call> resultHandler)
            throws org.apache.thrift.TException

Specified by:

status in interface TTransactionServer.AsyncIface

Throws:

org.apache.thrift.TException

truncateInvalidTx

public void truncateInvalidTx(Set<Long> txns,
                              org.apache.thrift.async.AsyncMethodCallback<TTransactionServer.AsyncClient.truncateInvalidTx_call> resultHandler)
                       throws org.apache.thrift.TException

Specified by:

truncateInvalidTx in interface TTransactionServer.AsyncIface

Throws:

org.apache.thrift.TException

truncateInvalidTxBefore

public void truncateInvalidTxBefore(long time,
                                    org.apache.thrift.async.AsyncMethodCallback<TTransactionServer.AsyncClient.truncateInvalidTxBefore_call> resultHandler)
                             throws org.apache.thrift.TException

Specified by:

truncateInvalidTxBefore in interface TTransactionServer.AsyncIface

Throws:

org.apache.thrift.TException

invalidTxSize

public void invalidTxSize(org.apache.thrift.async.AsyncMethodCallback<TTransactionServer.AsyncClient.invalidTxSize_call> resultHandler)
                   throws org.apache.thrift.TException

Specified by:

invalidTxSize in interface TTransactionServer.AsyncIface

Throws:

org.apache.thrift.TException

checkpoint

public void checkpoint(TTransaction tx,
                       org.apache.thrift.async.AsyncMethodCallback<TTransactionServer.AsyncClient.checkpoint_call> resultHandler)
                throws org.apache.thrift.TException

Specified by:

checkpoint in interface TTransactionServer.AsyncIface

Throws:

org.apache.thrift.TException

pruneNow

public void pruneNow(org.apache.thrift.async.AsyncMethodCallback<TTransactionServer.AsyncClient.pruneNow_call> resultHandler)
              throws org.apache.thrift.TException

Specified by:

pruneNow in interface TTransactionServer.AsyncIface

Throws:

org.apache.thrift.TException