beehive.thrift

Class PeerInterface_thrift.AsyncClient

java.lang.Object

org.apache.thrift.async.TAsyncClient

beehive.thrift.PeerInterface_thrift.AsyncClient

All Implemented Interfaces:

PeerInterface_thrift.AsyncIface

Enclosing class:

PeerInterface_thrift

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

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	PeerInterface_thrift.AsyncClient.abort_peer_thrift_call
static class	PeerInterface_thrift.AsyncClient.commit_peer_thrift_call
static class	PeerInterface_thrift.AsyncClient.Factory
static class	PeerInterface_thrift.AsyncClient.getCtsSts_peer_thrift_call
static class	PeerInterface_thrift.AsyncClient.getSTS_peer_thrift_call
static class	PeerInterface_thrift.AsyncClient.reportCompletion_peer_thrift_call
static class	PeerInterface_thrift.AsyncClient.reportCompletionBatch_peer_thrift_call
static class	PeerInterface_thrift.AsyncClient.validate_peer_thrift_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	abort_peer_thrift(long startTS, long transactionId, boolean bReleaseLock, org.apache.thrift.async.AsyncMethodCallback resultHandler)
void	commit_peer_thrift(long startTS, long commitTS, long transactionId, org.apache.thrift.async.AsyncMethodCallback resultHandler)
void	getCtsSts_peer_thrift(org.apache.thrift.async.AsyncMethodCallback resultHandler)
void	getSTS_peer_thrift(org.apache.thrift.async.AsyncMethodCallback resultHandler)
void	reportCompletion_peer_thrift(long commitTS, org.apache.thrift.async.AsyncMethodCallback resultHandler)
void	reportCompletionBatch_peer_thrift(java.util.List<java.lang.Long> commitTS, org.apache.thrift.async.AsyncMethodCallback resultHandler)
void	validate_peer_thrift(long startTS, RWSetInfo_thrift rwSet, long transactionId, org.apache.thrift.async.AsyncMethodCallback 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

reportCompletion_peer_thrift

public void reportCompletion_peer_thrift(long commitTS,
                                         org.apache.thrift.async.AsyncMethodCallback resultHandler)
                                  throws org.apache.thrift.TException

Specified by:

reportCompletion_peer_thrift in interface PeerInterface_thrift.AsyncIface

Throws:

org.apache.thrift.TException

reportCompletionBatch_peer_thrift

public void reportCompletionBatch_peer_thrift(java.util.List<java.lang.Long> commitTS,
                                              org.apache.thrift.async.AsyncMethodCallback resultHandler)
                                       throws org.apache.thrift.TException

Specified by:

reportCompletionBatch_peer_thrift in interface PeerInterface_thrift.AsyncIface

Throws:

org.apache.thrift.TException

validate_peer_thrift

public void validate_peer_thrift(long startTS,
                                 RWSetInfo_thrift rwSet,
                                 long transactionId,
                                 org.apache.thrift.async.AsyncMethodCallback resultHandler)
                          throws org.apache.thrift.TException

Specified by:

validate_peer_thrift in interface PeerInterface_thrift.AsyncIface

Throws:

org.apache.thrift.TException

getSTS_peer_thrift

public void getSTS_peer_thrift(org.apache.thrift.async.AsyncMethodCallback resultHandler)
                        throws org.apache.thrift.TException

Specified by:

getSTS_peer_thrift in interface PeerInterface_thrift.AsyncIface

Throws:

org.apache.thrift.TException

getCtsSts_peer_thrift

public void getCtsSts_peer_thrift(org.apache.thrift.async.AsyncMethodCallback resultHandler)
                           throws org.apache.thrift.TException

Specified by:

getCtsSts_peer_thrift in interface PeerInterface_thrift.AsyncIface

Throws:

org.apache.thrift.TException

commit_peer_thrift

public void commit_peer_thrift(long startTS,
                               long commitTS,
                               long transactionId,
                               org.apache.thrift.async.AsyncMethodCallback resultHandler)
                        throws org.apache.thrift.TException

Specified by:

commit_peer_thrift in interface PeerInterface_thrift.AsyncIface

Throws:

org.apache.thrift.TException

abort_peer_thrift

public void abort_peer_thrift(long startTS,
                              long transactionId,
                              boolean bReleaseLock,
                              org.apache.thrift.async.AsyncMethodCallback resultHandler)
                       throws org.apache.thrift.TException

Specified by:

abort_peer_thrift in interface PeerInterface_thrift.AsyncIface

Throws:

org.apache.thrift.TException