- readAll(Reader) - Static method in class io.parallec.core.util.PcFileNetworkIoUtils
-
Read all.
- readFileContentToString(String) - Static method in class io.parallec.core.util.PcFileNetworkIoUtils
-
Read file content to string.
- readFileToInputStream(String) - Static method in class io.parallec.core.util.PcFileNetworkIoUtils
-
20140907: for key management get from file to input stream.
- readJsonFromUrlWithCmsHeader(String) - Static method in class io.parallec.core.taskbuilder.targethosts.TargetHostsBuilderHelperCms
-
removed header (only used for authorization for PP) 2015.08
- readStringFromUrlGeneric(String) - Static method in class io.parallec.core.util.PcFileNetworkIoUtils
-
Read string from url generic.
- receiveTime - Variable in class io.parallec.core.actor.message.ResponseOnSingeRequest
-
The receive time.
- receiveTime - Variable in class io.parallec.core.ResponseOnSingleTask
-
The receive time.
- receiveTimeInManager - Variable in class io.parallec.core.ResponseOnSingleTask
-
The receive time in manager.
- REDUCE_LEN - Static variable in class io.parallec.core.actor.ExecutionManager
-
The Constant REDUCE_LEN.
- regex - Variable in class io.parallec.core.FilterRegex
-
The regex.
- REGEX_ERROR_SUMMARY - Static variable in class io.parallec.core.util.PcConstants
-
to get the errorSummary
- reinit() - Method in class io.parallec.core.resources.HttpClientStore
-
close and clean up the http client, then create the new ones.
- reinit() - Method in class io.parallec.core.resources.TcpUdpSshPingResourceStore
-
close and clean up the http client, then create the new ones.
- reinitHttpClients() - Method in class io.parallec.core.ParallelClient
-
Reinit http clients.
- reinitIfClosed() - Method in class io.parallec.core.ParallelClient
-
Auto re-initialize external resourced
if resources have been already released.
- releaseExternalResources() - Method in class io.parallec.core.ParallelClient
-
Releases the external resources that this object depends on.
- removeDuplicateNodeList(List<String>) - Static method in class io.parallec.core.util.PcTargetHostsUtils
-
Removes the duplicate node list.
- removeTaskFromInProgressMap(String) - Method in class io.parallec.core.task.ParallelTaskManager
-
Removes the task from in progress map.
- removeTaskFromWaitQ(ParallelTask) - Method in class io.parallec.core.task.ParallelTaskManager
-
Removes the task from wait q.
- renderJson(Object) - Static method in class io.parallec.core.util.PcStringUtils
-
Render json.
- replaceDefaultFullRequestContent(String) - Static method in class io.parallec.core.bean.HttpMeta
-
Replace default full request content.
- replaceErrorMsg(String) - Static method in class io.parallec.core.util.PcErrorMsgUtils
-
Replace error msg.
- replaceFullRequestContent(String, String) - Static method in class io.parallec.core.bean.HttpMeta
-
Replace full request content.
- replaceHttpHeaderMapNodeSpecific(Map<String, String>, Map<String, String>) - Static method in class io.parallec.core.util.PcHttpUtils
-
!!!! ASSUMPTION: all VAR exists in HTTP Header must of type:
APIVARREPLACE_NAME_PREFIX_HTTP_HEADER
20140310 This may be costly (O(n^2)) of the updated related # of headers;
# of parameters in the requests.
- replacementVarMap - Variable in class io.parallec.core.ParallelTask
-
The replacement var map.
- replacementVarMap - Variable in class io.parallec.core.ParallelTaskBuilder
-
The replacement var map.
- replacementVarMap - Variable in class io.parallec.core.task.ParallelTaskBean
-
The replacement var map.
- replacementVarMapNodeSpecific - Variable in class io.parallec.core.ParallelTask
-
The replacement var map node specific.
- replacementVarMapNodeSpecific - Variable in class io.parallec.core.ParallelTaskBuilder
-
The replacement var map node specific.
- replacementVarMapNodeSpecific - Variable in class io.parallec.core.task.ParallelTaskBean
-
The replacement var map node specific.
- replaceStrByMap(Map<String, String>, String) - Static method in class io.parallec.core.actor.message.NodeReqResponse
-
20130507: auto replace part.
- reply(ParallelTaskState, Exception) - Method in class io.parallec.core.actor.ExecutionManager
-
reply will terminal the actor and return the results.
- reply(String, boolean, String, String, String, int, Map<String, List<String>>) - Method in class io.parallec.core.actor.HttpWorker
-
Reply.
- reply(boolean, String, String, String, int, String, Map<String, List<String>>) - Method in class io.parallec.core.actor.OperationWorker
-
Reply.
- reply(String, boolean, String, String, String, int) - Method in class io.parallec.core.actor.PingWorker
-
Reply.
- reply(String, boolean, String, String, String, int) - Method in class io.parallec.core.actor.SshWorker
-
Reply.
- reply(String, boolean, String, String, String, int) - Method in class io.parallec.core.actor.TcpWorker
-
First close the connection.
- reply(String, boolean, String, String, String, int) - Method in class io.parallec.core.actor.UdpWorker
-
First close the connection.
- replyErrors(String, String, String, int) - Method in class io.parallec.core.actor.OperationWorker
-
Reply used in error cases.
- request - Variable in class io.parallec.core.actor.OperationWorker
-
The request.
- request - Variable in class io.parallec.core.ResponseOnSingleTask
-
The request.
- REQUEST_BODY_PLACE_HOLDER - Static variable in class io.parallec.core.util.PcConstants
-
The Constant REQUEST_BODY_PLACE_HOLDER.
- REQUEST_CANCELED - Static variable in class io.parallec.core.util.PcConstants
-
- REQUEST_PARAMETER_HTTP_HEADER_PREFIX - Static variable in class io.parallec.core.util.PcConstants
-
The request parameter http header prefix.
- requestContent - Variable in class io.parallec.core.bean.TaskRequest
-
The request content.
- requestCount - Variable in class io.parallec.core.actor.ExecutionManager
-
The request count.
- requestNum - Variable in class io.parallec.core.ParallelTask
-
The request num.
- requestNum - Variable in class io.parallec.core.task.ParallelTaskBean
-
The request num.
- requestNumActual - Variable in class io.parallec.core.ParallelTask
-
The request num actual.
- requestNumActual - Variable in class io.parallec.core.task.ParallelTaskBean
-
The request num actual.
- requestParameters - Variable in class io.parallec.core.actor.message.NodeReqResponse
-
The request parameters.
- requestPort - Variable in class io.parallec.core.bean.HttpMeta
-
The request port.
- requestProtocol - Variable in class io.parallec.core.ParallelTask
-
The request protocol.
- requestProtocol - Variable in class io.parallec.core.ParallelTaskBuilder
-
The request protocol.
- RequestProtocol - Enum in io.parallec.core
-
The Enum RequestProtocol.
- RequestProtocol() - Constructor for enum io.parallec.core.RequestProtocol
-
- requestReplacementType - Variable in class io.parallec.core.ParallelTask
-
The request replacement type.
- requestReplacementType - Variable in class io.parallec.core.ParallelTaskBuilder
-
The request replacement type.
- requestReplacementType - Variable in class io.parallec.core.task.ParallelTaskBean
-
The request replacement type.
- RequestReplacementType - Enum in io.parallec.core.task
-
The Enum RequestReplacementType.
- RequestReplacementType() - Constructor for enum io.parallec.core.task.RequestReplacementType
-
- RequestToBatchSenderAsstManager - Class in io.parallec.core.actor.message
-
The Class RequestToBatchSenderAsstManager.
- RequestToBatchSenderAsstManager() - Constructor for class io.parallec.core.actor.message.RequestToBatchSenderAsstManager
-
used for pojo test only.
- RequestToBatchSenderAsstManager(String, long, List<ActorRef>, ActorRef, int) - Constructor for class io.parallec.core.actor.message.RequestToBatchSenderAsstManager
-
Instantiates a new request to batch sender asst manager.
- requestTotalCount - Variable in class io.parallec.core.actor.AssistantExecutionManager
-
The request total count.
- requestUrl - Variable in class io.parallec.core.actor.HttpWorker
-
The request url.
- requestUrlPostfix - Variable in class io.parallec.core.bean.HttpMeta
-
The request url postfix.
- RequestWorkerMsgType - Enum in io.parallec.core.actor.message.type
-
The Enum RequestWorkerMsgType.
- RequestWorkerMsgType() - Constructor for enum io.parallec.core.actor.message.type.RequestWorkerMsgType
-
- resourcePath - Variable in class io.parallec.core.bean.TaskRequest
-
The resource path.
- response - Variable in class io.parallec.core.actor.OperationWorker
-
The response.
- responseBody - Variable in class io.parallec.core.actor.message.ResponseOnSingeRequest
-
The response body.
- responseContent - Variable in class io.parallec.core.ResponseOnSingleTask
-
The response content.
- responseContext - Variable in class io.parallec.core.bean.TaskRequest
-
The response context.
- responseContext - Variable in class io.parallec.core.ParallelTask
-
The response context.
- responseContext - Variable in class io.parallec.core.ParallelTaskBuilder
-
The response context.
- responseContext - Variable in class io.parallec.core.task.ParallelTaskBean
-
The response context.
- responseCount - Variable in class io.parallec.core.actor.AssistantExecutionManager
-
The response count.
- responseCount - Variable in class io.parallec.core.actor.ExecutionManager
-
The response count.
- responseCount - Variable in class io.parallec.core.actor.message.ResponseCountToBatchSenderAsstManager
-
The response count.
- responseCount - Variable in class io.parallec.core.actor.message.ResponseFromManager
-
- ResponseCountToBatchSenderAsstManager - Class in io.parallec.core.actor.message
-
Receive count from the manager to asst manager; for flow control.
- ResponseCountToBatchSenderAsstManager(int) - Constructor for class io.parallec.core.actor.message.ResponseCountToBatchSenderAsstManager
-
Instantiates a new response count to batch sender asst manager.
- responsedNum - Variable in class io.parallec.core.ParallelTask
-
The responsed num.
- responsedNum - Variable in class io.parallec.core.task.ParallelTaskBean
-
The response received number.
- ResponseFromManager - Class in io.parallec.core.actor.message
-
The Class BatchResponseFromManager.
- ResponseFromManager(int) - Constructor for class io.parallec.core.actor.message.ResponseFromManager
-
- responseFuture - Variable in class io.parallec.core.actor.HttpWorker
-
The response future.
- responseFuture - Variable in class io.parallec.core.actor.PingWorker
-
The response future.
- responseFuture - Variable in class io.parallec.core.actor.SshWorker
-
The response future.
- responseHeaderMeta - Variable in class io.parallec.core.actor.HttpWorker
-
The response header meta: which keys are needed to get from response
header.
- responseHeaderMeta - Variable in class io.parallec.core.bean.HttpMeta
-
The response header meta: which keys are needed to get from response header.
- ResponseHeaderMeta - Class in io.parallec.core.bean
-
- ResponseHeaderMeta(List<String>, boolean) - Constructor for class io.parallec.core.bean.ResponseHeaderMeta
-
Instantiates a new response header meta.
- responseHeaderMeta - Variable in class io.parallec.core.bean.TaskRequest
-
The response header meta.
- responseHeaders - Variable in class io.parallec.core.actor.message.ResponseOnSingeRequest
-
The response headers: keys are lower cased.
- responseHeaders - Variable in class io.parallec.core.ResponseOnSingleTask
-
The response headers.
- responseMap - Variable in class io.parallec.core.actor.ExecutionManager
-
The response map.
- ResponseOnSingeRequest - Class in io.parallec.core.actor.message
-
A single HTTP response for each http request
Note that the failObtainResponse in the response is whether work successfully
received.
- ResponseOnSingeRequest(String, boolean, String, String, String, int, String, Map<String, List<String>>) - Constructor for class io.parallec.core.actor.message.ResponseOnSingeRequest
-
Instantiates a new response on singe request.
- ResponseOnSingeRequest() - Constructor for class io.parallec.core.actor.message.ResponseOnSingeRequest
-
Instantiates a new response on singe request.
- ResponseOnSingleTask - Class in io.parallec.core
-
this includes the request each target host will have one.
- ResponseOnSingleTask() - Constructor for class io.parallec.core.ResponseOnSingleTask
-
Instantiates a new response on single task.
- responseSb - Variable in class io.parallec.core.actor.TcpWorker
-
The response sb.
- responseSb - Variable in class io.parallec.core.actor.UdpWorker
-
The response sb.
- run() - Method in class io.parallec.core.task.CapacityAwareTaskScheduler
-
- runAsSuperUser - Variable in class io.parallec.core.bean.ssh.SshMeta
-
The priv key for runAsSuperUser.