Package | Description |
---|---|
io.parallec.core.actor |
Actors to execute parallel task and return responses.
|
io.parallec.core.actor.poll |
Classes for handling Async APIs with polling progress APIs
with success / failure criteria
|
io.parallec.core.commander.workflow.ssh |
Work flow utilities on ssh.
|
Modifier and Type | Field and Description |
---|---|
(package private) com.ning.http.client.ListenableFuture<ResponseOnSingeRequest> |
HttpWorker.responseFuture
The response future.
|
private java.util.concurrent.Future<ResponseOnSingeRequest> |
SshWorker.responseFuture
The response future.
|
private java.util.concurrent.Future<ResponseOnSingeRequest> |
PingWorker.responseFuture
The response future.
|
Modifier and Type | Method and Description |
---|---|
ResponseOnSingeRequest |
SshWorker.SshTask.call() |
ResponseOnSingeRequest |
PingWorker.PingTask.call() |
ResponseOnSingeRequest |
HttpWorker.onComplete(com.ning.http.client.Response response)
On complete.
|
ResponseOnSingeRequest |
HttpWorker.HttpAsyncHandler.onCompleted(com.ning.http.client.Response response) |
Modifier and Type | Method and Description |
---|---|
java.util.concurrent.Future<ResponseOnSingeRequest> |
SshWorker.getResponseFuture()
Gets the response future.
|
java.util.concurrent.Future<ResponseOnSingeRequest> |
PingWorker.getResponseFuture()
Gets the response future.
|
Modifier and Type | Method and Description |
---|---|
private void |
OperationWorker.handleHttpWorkerResponse(ResponseOnSingeRequest respOnSingleReq)
Handle http worker response.
|
void |
SshWorker.onComplete(ResponseOnSingeRequest sshResponse)
On complete.
|
void |
PingWorker.onComplete(ResponseOnSingeRequest pingResponse)
On complete.
|
Modifier and Type | Method and Description |
---|---|
void |
SshWorker.setResponseFuture(java.util.concurrent.Future<ResponseOnSingeRequest> responseFuture)
Sets the response future.
|
void |
PingWorker.setResponseFuture(java.util.concurrent.Future<ResponseOnSingeRequest> responseFuture)
Sets the response future.
|
Modifier and Type | Method and Description |
---|---|
double |
HttpPollerProcessor.getProgressFromResponse(ResponseOnSingeRequest myResponse)
Gets the progress from response.
|
java.lang.String |
HttpPollerProcessor.getUuidFromResponse(ResponseOnSingeRequest myResponse)
Gets the uuid from response.
|
boolean |
HttpPollerProcessor.ifTaskCompletedSuccessOrFailureFromResponse(ResponseOnSingeRequest myResponse)
If task completed success or failure from response.
|
boolean |
HttpPollerProcessor.ifThereIsErrorInResponse(ResponseOnSingeRequest myResponse)
If there is error in response.
|
Modifier and Type | Method and Description |
---|---|
ResponseOnSingeRequest |
SshProvider.executeAndGenResponse(com.jcraft.jsch.ChannelExec channel)
Seems there are bad naming in the library the sysout is in
channel.getInputStream(); the syserr is in
((ChannelExec)channel).setErrStream(os);
|
ResponseOnSingeRequest |
SshProvider.executeSshCommand()
finally: will close the connection.
|
ResponseOnSingeRequest |
SshProvider.genErrorResponse(java.lang.Exception t)
Gen error response.
|