- onComplete(Response) - Method in class io.parallec.core.actor.HttpWorker
-
On complete.
- onComplete(ResponseOnSingeRequest) - Method in class io.parallec.core.actor.PingWorker
-
On complete.
- onComplete(ResponseOnSingeRequest) - Method in class io.parallec.core.actor.SshWorker
-
On complete.
- onComplete(String, boolean, String, String, String, int) - Method in class io.parallec.core.actor.TcpWorker
-
On complete.
- onComplete(String, boolean, String, String, String, int) - Method in class io.parallec.core.actor.UdpWorker
-
On complete.
- onCompleted(Response) - Method in class io.parallec.core.actor.HttpWorker.HttpAsyncHandler
-
- onCompleted(ResponseOnSingleTask, Map<String, Object>) - Method in interface io.parallec.core.ParallecResponseHandler
-
When timeout / error occurred or response received for the target host,
will trigger execution of onCompleted().
- onReceive(Object) - Method in class io.parallec.core.actor.AssistantExecutionManager
-
- onReceive(Object) - Method in class io.parallec.core.actor.ExecutionManager
-
- onReceive(Object) - Method in class io.parallec.core.actor.HttpWorker
-
- onReceive(Object) - Method in class io.parallec.core.actor.OperationWorker
-
- onReceive(Object) - Method in class io.parallec.core.actor.PingWorker
-
- onReceive(Object) - Method in class io.parallec.core.actor.SshWorker
-
- onReceive(Object) - Method in class io.parallec.core.actor.TcpWorker
-
- onReceive(Object) - Method in class io.parallec.core.actor.UdpWorker
-
- onThrowable(Throwable) - Method in class io.parallec.core.actor.HttpWorker.HttpAsyncHandler
-
- onThrowable(Throwable) - Method in class io.parallec.core.actor.HttpWorker
-
On throwable.
- OPERATION_SUCCESSFUL - Static variable in class io.parallec.core.util.PcConstants
-
The Constant OPERATION_SUCCESSFUL.
- OPERATION_TIMEOUT - Static variable in class io.parallec.core.util.PcConstants
-
- operationTimeMillis - Variable in class io.parallec.core.ResponseOnSingleTask
-
The operation time millis.
- operationTimeout() - Method in class io.parallec.core.actor.OperationWorker
-
will trigger workers to cancel then wait for it to report back.
- OperationWorker - Class in io.parallec.core.actor
-
AHC based.
- OperationWorker(TaskRequest, AsyncHttpClient, HttpPollerProcessor) - Constructor for class io.parallec.core.actor.OperationWorker
-
Instantiates a new operation worker.
- OperationWorkerMsgType - Enum in io.parallec.core.actor.message.type
-
The Enum OperationWorkerMsgType.
- OperationWorkerMsgType() - Constructor for enum io.parallec.core.actor.message.type.OperationWorkerMsgType
-
- originalManager - Variable in class io.parallec.core.actor.AssistantExecutionManager
-
The original manager.