public static class WorkerService.AsyncClient extends org.apache.thrift.async.TAsyncClient implements WorkerService.AsyncIface
| Modifier and Type | Class and Description |
|---|---|
static class |
WorkerService.AsyncClient.accessBlock_call |
static class |
WorkerService.AsyncClient.addCheckpoint_call |
static class |
WorkerService.AsyncClient.asyncCheckpoint_call |
static class |
WorkerService.AsyncClient.cacheBlock_call |
static class |
WorkerService.AsyncClient.Factory |
static class |
WorkerService.AsyncClient.getDataFolder_call |
static class |
WorkerService.AsyncClient.getUserTempFolder_call |
static class |
WorkerService.AsyncClient.getUserUnderfsTempFolder_call |
static class |
WorkerService.AsyncClient.lockBlock_call |
static class |
WorkerService.AsyncClient.requestSpace_call |
static class |
WorkerService.AsyncClient.returnSpace_call |
static class |
WorkerService.AsyncClient.unlockBlock_call |
static class |
WorkerService.AsyncClient.userHeartbeat_call |
| Constructor and Description |
|---|
WorkerService.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 |
accessBlock(long blockId,
org.apache.thrift.async.AsyncMethodCallback<WorkerService.AsyncClient.accessBlock_call> resultHandler) |
void |
addCheckpoint(long userId,
int fileId,
org.apache.thrift.async.AsyncMethodCallback<WorkerService.AsyncClient.addCheckpoint_call> resultHandler) |
void |
asyncCheckpoint(int fileId,
org.apache.thrift.async.AsyncMethodCallback<WorkerService.AsyncClient.asyncCheckpoint_call> resultHandler) |
void |
cacheBlock(long userId,
long blockId,
org.apache.thrift.async.AsyncMethodCallback<WorkerService.AsyncClient.cacheBlock_call> resultHandler) |
void |
getDataFolder(org.apache.thrift.async.AsyncMethodCallback<WorkerService.AsyncClient.getDataFolder_call> resultHandler) |
void |
getUserTempFolder(long userId,
org.apache.thrift.async.AsyncMethodCallback<WorkerService.AsyncClient.getUserTempFolder_call> resultHandler) |
void |
getUserUnderfsTempFolder(long userId,
org.apache.thrift.async.AsyncMethodCallback<WorkerService.AsyncClient.getUserUnderfsTempFolder_call> resultHandler) |
void |
lockBlock(long blockId,
long userId,
org.apache.thrift.async.AsyncMethodCallback<WorkerService.AsyncClient.lockBlock_call> resultHandler) |
void |
requestSpace(long userId,
long requestBytes,
org.apache.thrift.async.AsyncMethodCallback<WorkerService.AsyncClient.requestSpace_call> resultHandler) |
void |
returnSpace(long userId,
long returnedBytes,
org.apache.thrift.async.AsyncMethodCallback<WorkerService.AsyncClient.returnSpace_call> resultHandler) |
void |
unlockBlock(long blockId,
long userId,
org.apache.thrift.async.AsyncMethodCallback<WorkerService.AsyncClient.unlockBlock_call> resultHandler) |
void |
userHeartbeat(long userId,
org.apache.thrift.async.AsyncMethodCallback<WorkerService.AsyncClient.userHeartbeat_call> resultHandler) |
public WorkerService.AsyncClient(org.apache.thrift.protocol.TProtocolFactory protocolFactory,
org.apache.thrift.async.TAsyncClientManager clientManager,
org.apache.thrift.transport.TNonblockingTransport transport)
public void accessBlock(long blockId,
org.apache.thrift.async.AsyncMethodCallback<WorkerService.AsyncClient.accessBlock_call> resultHandler)
throws org.apache.thrift.TException
accessBlock in interface WorkerService.AsyncIfaceorg.apache.thrift.TExceptionpublic void addCheckpoint(long userId,
int fileId,
org.apache.thrift.async.AsyncMethodCallback<WorkerService.AsyncClient.addCheckpoint_call> resultHandler)
throws org.apache.thrift.TException
addCheckpoint in interface WorkerService.AsyncIfaceorg.apache.thrift.TExceptionpublic void asyncCheckpoint(int fileId,
org.apache.thrift.async.AsyncMethodCallback<WorkerService.AsyncClient.asyncCheckpoint_call> resultHandler)
throws org.apache.thrift.TException
asyncCheckpoint in interface WorkerService.AsyncIfaceorg.apache.thrift.TExceptionpublic void cacheBlock(long userId,
long blockId,
org.apache.thrift.async.AsyncMethodCallback<WorkerService.AsyncClient.cacheBlock_call> resultHandler)
throws org.apache.thrift.TException
cacheBlock in interface WorkerService.AsyncIfaceorg.apache.thrift.TExceptionpublic void getDataFolder(org.apache.thrift.async.AsyncMethodCallback<WorkerService.AsyncClient.getDataFolder_call> resultHandler) throws org.apache.thrift.TException
getDataFolder in interface WorkerService.AsyncIfaceorg.apache.thrift.TExceptionpublic void getUserTempFolder(long userId,
org.apache.thrift.async.AsyncMethodCallback<WorkerService.AsyncClient.getUserTempFolder_call> resultHandler)
throws org.apache.thrift.TException
getUserTempFolder in interface WorkerService.AsyncIfaceorg.apache.thrift.TExceptionpublic void getUserUnderfsTempFolder(long userId,
org.apache.thrift.async.AsyncMethodCallback<WorkerService.AsyncClient.getUserUnderfsTempFolder_call> resultHandler)
throws org.apache.thrift.TException
getUserUnderfsTempFolder in interface WorkerService.AsyncIfaceorg.apache.thrift.TExceptionpublic void lockBlock(long blockId,
long userId,
org.apache.thrift.async.AsyncMethodCallback<WorkerService.AsyncClient.lockBlock_call> resultHandler)
throws org.apache.thrift.TException
lockBlock in interface WorkerService.AsyncIfaceorg.apache.thrift.TExceptionpublic void returnSpace(long userId,
long returnedBytes,
org.apache.thrift.async.AsyncMethodCallback<WorkerService.AsyncClient.returnSpace_call> resultHandler)
throws org.apache.thrift.TException
returnSpace in interface WorkerService.AsyncIfaceorg.apache.thrift.TExceptionpublic void requestSpace(long userId,
long requestBytes,
org.apache.thrift.async.AsyncMethodCallback<WorkerService.AsyncClient.requestSpace_call> resultHandler)
throws org.apache.thrift.TException
requestSpace in interface WorkerService.AsyncIfaceorg.apache.thrift.TExceptionpublic void unlockBlock(long blockId,
long userId,
org.apache.thrift.async.AsyncMethodCallback<WorkerService.AsyncClient.unlockBlock_call> resultHandler)
throws org.apache.thrift.TException
unlockBlock in interface WorkerService.AsyncIfaceorg.apache.thrift.TExceptionpublic void userHeartbeat(long userId,
org.apache.thrift.async.AsyncMethodCallback<WorkerService.AsyncClient.userHeartbeat_call> resultHandler)
throws org.apache.thrift.TException
userHeartbeat in interface WorkerService.AsyncIfaceorg.apache.thrift.TExceptionCopyright © 2014. All rights reserved.