public static class PeerInterface_thrift.AsyncClient extends org.apache.thrift.async.TAsyncClient implements PeerInterface_thrift.AsyncIface
| 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 |
| Constructor and Description |
|---|
AsyncClient(org.apache.thrift.protocol.TProtocolFactory protocolFactory,
org.apache.thrift.async.TAsyncClientManager clientManager,
org.apache.thrift.transport.TNonblockingTransport transport) |
| 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) |
public AsyncClient(org.apache.thrift.protocol.TProtocolFactory protocolFactory,
org.apache.thrift.async.TAsyncClientManager clientManager,
org.apache.thrift.transport.TNonblockingTransport transport)
public void reportCompletion_peer_thrift(long commitTS,
org.apache.thrift.async.AsyncMethodCallback resultHandler)
throws org.apache.thrift.TException
reportCompletion_peer_thrift in interface PeerInterface_thrift.AsyncIfaceorg.apache.thrift.TExceptionpublic void reportCompletionBatch_peer_thrift(java.util.List<java.lang.Long> commitTS,
org.apache.thrift.async.AsyncMethodCallback resultHandler)
throws org.apache.thrift.TException
reportCompletionBatch_peer_thrift in interface PeerInterface_thrift.AsyncIfaceorg.apache.thrift.TExceptionpublic void validate_peer_thrift(long startTS,
RWSetInfo_thrift rwSet,
long transactionId,
org.apache.thrift.async.AsyncMethodCallback resultHandler)
throws org.apache.thrift.TException
validate_peer_thrift in interface PeerInterface_thrift.AsyncIfaceorg.apache.thrift.TExceptionpublic void getSTS_peer_thrift(org.apache.thrift.async.AsyncMethodCallback resultHandler)
throws org.apache.thrift.TException
getSTS_peer_thrift in interface PeerInterface_thrift.AsyncIfaceorg.apache.thrift.TExceptionpublic void getCtsSts_peer_thrift(org.apache.thrift.async.AsyncMethodCallback resultHandler)
throws org.apache.thrift.TException
getCtsSts_peer_thrift in interface PeerInterface_thrift.AsyncIfaceorg.apache.thrift.TExceptionpublic void commit_peer_thrift(long startTS,
long commitTS,
long transactionId,
org.apache.thrift.async.AsyncMethodCallback resultHandler)
throws org.apache.thrift.TException
commit_peer_thrift in interface PeerInterface_thrift.AsyncIfaceorg.apache.thrift.TExceptionpublic void abort_peer_thrift(long startTS,
long transactionId,
boolean bReleaseLock,
org.apache.thrift.async.AsyncMethodCallback resultHandler)
throws org.apache.thrift.TException
abort_peer_thrift in interface PeerInterface_thrift.AsyncIfaceorg.apache.thrift.TException