org.apache.tephra.distributed.thrift

Class TTransactionServer.Client

java.lang.Object

org.apache.thrift.TServiceClient

org.apache.tephra.distributed.thrift.TTransactionServer.Client

All Implemented Interfaces:

TTransactionServer.Iface

Enclosing class:

TTransactionServer

public static class TTransactionServer.Client
extends org.apache.thrift.TServiceClient
implements TTransactionServer.Iface

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	TTransactionServer.Client.Factory

Field Summary

Fields inherited from class org.apache.thrift.TServiceClient

iprot_, oprot_, seqid_

Constructor Summary

Constructors

Constructor and Description
TTransactionServer.Client(org.apache.thrift.protocol.TProtocol prot)
TTransactionServer.Client(org.apache.thrift.protocol.TProtocol iprot, org.apache.thrift.protocol.TProtocol oprot)

Method Summary

Methods

Modifier and Type	Method and Description
void	abortTx(TTransaction tx)
TBoolean	canCommitTx(TTransaction tx, Set<ByteBuffer> changes)
TTransaction	checkpoint(TTransaction tx)
TBoolean	commitTx(TTransaction tx)
ByteBuffer	getSnapshot()
boolean	invalidateTx(long tx)
int	invalidTxSize()
void	recv_abortTx()
TBoolean	recv_canCommitTx()
TTransaction	recv_checkpoint()
TBoolean	recv_commitTx()
ByteBuffer	recv_getSnapshot()
boolean	recv_invalidateTx()
int	recv_invalidTxSize()
void	recv_resetState()
TTransaction	recv_startLong()
TTransaction	recv_startLongClientId()
TTransaction	recv_startShort()
TTransaction	recv_startShortClientId()
TTransaction	recv_startShortTimeout()
TTransaction	recv_startShortWithClientIdAndTimeOut()
TTransaction	recv_startShortWithTimeout()
String	recv_status()
TBoolean	recv_truncateInvalidTx()
TBoolean	recv_truncateInvalidTxBefore()
void	resetState()
void	send_abortTx(TTransaction tx)
void	send_canCommitTx(TTransaction tx, Set<ByteBuffer> changes)
void	send_checkpoint(TTransaction tx)
void	send_commitTx(TTransaction tx)
void	send_getSnapshot()
void	send_invalidateTx(long tx)
void	send_invalidTxSize()
void	send_resetState()
void	send_startLong()
void	send_startLongClientId(String clientId)
void	send_startShort()
void	send_startShortClientId(String clientId)
void	send_startShortTimeout(int timeout)
void	send_startShortWithClientIdAndTimeOut(String clientId, int timeout)
void	send_startShortWithTimeout(int timeout)
void	send_status()
void	send_truncateInvalidTx(Set<Long> txns)
void	send_truncateInvalidTxBefore(long time)
TTransaction	startLong()
TTransaction	startLongClientId(String clientId)
TTransaction	startShort()
TTransaction	startShortClientId(String clientId)
TTransaction	startShortTimeout(int timeout)
TTransaction	startShortWithClientIdAndTimeOut(String clientId, int timeout)
TTransaction	startShortWithTimeout(int timeout)
String	status()
TBoolean	truncateInvalidTx(Set<Long> txns)
TBoolean	truncateInvalidTxBefore(long time)

Methods inherited from class org.apache.thrift.TServiceClient

getInputProtocol, getOutputProtocol, receiveBase, sendBase

Methods inherited from class java.lang.Object

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

Constructor Detail

TTransactionServer.Client

public TTransactionServer.Client(org.apache.thrift.protocol.TProtocol prot)

TTransactionServer.Client

public TTransactionServer.Client(org.apache.thrift.protocol.TProtocol iprot,
                         org.apache.thrift.protocol.TProtocol oprot)

Method Detail

startLong

public TTransaction startLong()
                       throws org.apache.thrift.TException

Specified by:

startLong in interface TTransactionServer.Iface

Throws:

org.apache.thrift.TException

send_startLong

public void send_startLong()
                    throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

recv_startLong

public TTransaction recv_startLong()
                            throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

startShort

public TTransaction startShort()
                        throws org.apache.thrift.TException

Specified by:

startShort in interface TTransactionServer.Iface

Throws:

org.apache.thrift.TException

send_startShort

public void send_startShort()
                     throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

recv_startShort

public TTransaction recv_startShort()
                             throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

startLongClientId

public TTransaction startLongClientId(String clientId)
                               throws TGenericException,
                                      org.apache.thrift.TException

Specified by:

startLongClientId in interface TTransactionServer.Iface

Throws:

TGenericException

org.apache.thrift.TException

send_startLongClientId

public void send_startLongClientId(String clientId)
                            throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

recv_startLongClientId

public TTransaction recv_startLongClientId()
                                    throws TGenericException,
                                           org.apache.thrift.TException

Throws:

TGenericException

org.apache.thrift.TException

startShortTimeout

public TTransaction startShortTimeout(int timeout)
                               throws org.apache.thrift.TException

Specified by:

startShortTimeout in interface TTransactionServer.Iface

Throws:

org.apache.thrift.TException

send_startShortTimeout

public void send_startShortTimeout(int timeout)
                            throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

recv_startShortTimeout

public TTransaction recv_startShortTimeout()
                                    throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

startShortClientId

public TTransaction startShortClientId(String clientId)
                                throws TGenericException,
                                       org.apache.thrift.TException

Specified by:

startShortClientId in interface TTransactionServer.Iface

Throws:

TGenericException

org.apache.thrift.TException

send_startShortClientId

public void send_startShortClientId(String clientId)
                             throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

recv_startShortClientId

public TTransaction recv_startShortClientId()
                                     throws TGenericException,
                                            org.apache.thrift.TException

Throws:

TGenericException

org.apache.thrift.TException

startShortWithClientIdAndTimeOut

public TTransaction startShortWithClientIdAndTimeOut(String clientId,
                                            int timeout)
                                              throws TGenericException,
                                                     org.apache.thrift.TException

Specified by:

startShortWithClientIdAndTimeOut in interface TTransactionServer.Iface

Throws:

TGenericException

org.apache.thrift.TException

send_startShortWithClientIdAndTimeOut

public void send_startShortWithClientIdAndTimeOut(String clientId,
                                         int timeout)
                                           throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

recv_startShortWithClientIdAndTimeOut

public TTransaction recv_startShortWithClientIdAndTimeOut()
                                                   throws TGenericException,
                                                          org.apache.thrift.TException

Throws:

TGenericException

org.apache.thrift.TException

startShortWithTimeout

public TTransaction startShortWithTimeout(int timeout)
                                   throws TGenericException,
                                          org.apache.thrift.TException

Specified by:

startShortWithTimeout in interface TTransactionServer.Iface

Throws:

TGenericException

org.apache.thrift.TException

send_startShortWithTimeout

public void send_startShortWithTimeout(int timeout)
                                throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

recv_startShortWithTimeout

public TTransaction recv_startShortWithTimeout()
                                        throws TGenericException,
                                               org.apache.thrift.TException

Throws:

TGenericException

org.apache.thrift.TException

canCommitTx

public TBoolean canCommitTx(TTransaction tx,
                   Set<ByteBuffer> changes)
                     throws TTransactionNotInProgressException,
                            org.apache.thrift.TException

Specified by:

canCommitTx in interface TTransactionServer.Iface

Throws:

TTransactionNotInProgressException

org.apache.thrift.TException

send_canCommitTx

public void send_canCommitTx(TTransaction tx,
                    Set<ByteBuffer> changes)
                      throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

recv_canCommitTx

public TBoolean recv_canCommitTx()
                          throws TTransactionNotInProgressException,
                                 org.apache.thrift.TException

Throws:

TTransactionNotInProgressException

org.apache.thrift.TException

commitTx

public TBoolean commitTx(TTransaction tx)
                  throws TTransactionNotInProgressException,
                         org.apache.thrift.TException

Specified by:

commitTx in interface TTransactionServer.Iface

Throws:

TTransactionNotInProgressException

org.apache.thrift.TException

send_commitTx

public void send_commitTx(TTransaction tx)
                   throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

recv_commitTx

public TBoolean recv_commitTx()
                       throws TTransactionNotInProgressException,
                              org.apache.thrift.TException

Throws:

TTransactionNotInProgressException

org.apache.thrift.TException

abortTx

public void abortTx(TTransaction tx)
             throws org.apache.thrift.TException

Specified by:

abortTx in interface TTransactionServer.Iface

Throws:

org.apache.thrift.TException

send_abortTx

public void send_abortTx(TTransaction tx)
                  throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

recv_abortTx

public void recv_abortTx()
                  throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

invalidateTx

public boolean invalidateTx(long tx)
                     throws org.apache.thrift.TException

Specified by:

invalidateTx in interface TTransactionServer.Iface

Throws:

org.apache.thrift.TException

send_invalidateTx

public void send_invalidateTx(long tx)
                       throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

recv_invalidateTx

public boolean recv_invalidateTx()
                          throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

getSnapshot

public ByteBuffer getSnapshot()
                       throws TTransactionCouldNotTakeSnapshotException,
                              org.apache.thrift.TException

Specified by:

getSnapshot in interface TTransactionServer.Iface

Throws:

TTransactionCouldNotTakeSnapshotException

org.apache.thrift.TException

send_getSnapshot

public void send_getSnapshot()
                      throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

recv_getSnapshot

public ByteBuffer recv_getSnapshot()
                            throws TTransactionCouldNotTakeSnapshotException,
                                   org.apache.thrift.TException

Throws:

TTransactionCouldNotTakeSnapshotException

org.apache.thrift.TException

resetState

public void resetState()
                throws org.apache.thrift.TException

Specified by:

resetState in interface TTransactionServer.Iface

Throws:

org.apache.thrift.TException

send_resetState

public void send_resetState()
                     throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

recv_resetState

public void recv_resetState()
                     throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

status

public String status()
              throws org.apache.thrift.TException

Specified by:

status in interface TTransactionServer.Iface

Throws:

org.apache.thrift.TException

send_status

public void send_status()
                 throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

recv_status

public String recv_status()
                   throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

truncateInvalidTx

public TBoolean truncateInvalidTx(Set<Long> txns)
                           throws org.apache.thrift.TException

Specified by:

truncateInvalidTx in interface TTransactionServer.Iface

Throws:

org.apache.thrift.TException

send_truncateInvalidTx

public void send_truncateInvalidTx(Set<Long> txns)
                            throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

recv_truncateInvalidTx

public TBoolean recv_truncateInvalidTx()
                                throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

truncateInvalidTxBefore

public TBoolean truncateInvalidTxBefore(long time)
                                 throws TInvalidTruncateTimeException,
                                        org.apache.thrift.TException

Specified by:

truncateInvalidTxBefore in interface TTransactionServer.Iface

Throws:

TInvalidTruncateTimeException

org.apache.thrift.TException

send_truncateInvalidTxBefore

public void send_truncateInvalidTxBefore(long time)
                                  throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

recv_truncateInvalidTxBefore

public TBoolean recv_truncateInvalidTxBefore()
                                      throws TInvalidTruncateTimeException,
                                             org.apache.thrift.TException

Throws:

TInvalidTruncateTimeException

org.apache.thrift.TException

invalidTxSize

public int invalidTxSize()
                  throws org.apache.thrift.TException

Specified by:

invalidTxSize in interface TTransactionServer.Iface

Throws:

org.apache.thrift.TException

send_invalidTxSize

public void send_invalidTxSize()
                        throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

recv_invalidTxSize

public int recv_invalidTxSize()
                       throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

checkpoint

public TTransaction checkpoint(TTransaction tx)
                        throws TTransactionNotInProgressException,
                               org.apache.thrift.TException

Specified by:

checkpoint in interface TTransactionServer.Iface

Throws:

TTransactionNotInProgressException

org.apache.thrift.TException

send_checkpoint

public void send_checkpoint(TTransaction tx)
                     throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

recv_checkpoint

public TTransaction recv_checkpoint()
                             throws TTransactionNotInProgressException,
                                    org.apache.thrift.TException

Throws:

TTransactionNotInProgressException

org.apache.thrift.TException