| Package | Description |
|---|---|
| io.parallec.core |
Main package, including most user-facing classes such as the ParallelClient,
ParallelTask etc.
|
| Modifier and Type | Method and Description |
|---|---|
ParallelTaskBuilder |
ParallelTaskBuilder.async()
Execute the task asynchronously.
|
ParallelTaskBuilder |
ParallelTaskBuilder.handleInManager()
Call response handler in manager (in a sequence after aggregation) Default mode.
|
ParallelTaskBuilder |
ParallelTaskBuilder.handleInWorker()
Call response handler in operation worker (in parallel before aggregation).
|
ParallelTaskBuilder |
ParallelClient.prepareHttpDelete(java.lang.String url)
Prepare a parallel HTTP DELETE Task.
|
ParallelTaskBuilder |
ParallelClient.prepareHttpGet(java.lang.String url)
Prepare a parallel HTTP GET Task.
|
ParallelTaskBuilder |
ParallelClient.prepareHttpHead(java.lang.String url)
Prepare a parallel HTTP HEAD Task.
|
ParallelTaskBuilder |
ParallelClient.prepareHttpOptions(java.lang.String url)
Prepare a parallel HTTP OPTION Task.
|
ParallelTaskBuilder |
ParallelClient.prepareHttpPost(java.lang.String url)
Prepare a parallel HTTP POST Task.
|
ParallelTaskBuilder |
ParallelClient.prepareHttpPut(java.lang.String url)
Prepare a parallel HTTP PUT Task.
|
ParallelTaskBuilder |
ParallelClient.preparePing()
Prepare a parallel PING Task.
|
ParallelTaskBuilder |
ParallelClient.prepareSsh()
Prepare a parallel SSH Task.
|
ParallelTaskBuilder |
ParallelClient.prepareTcp(java.lang.String command)
Prepare a parallel TCP Task.
|
ParallelTaskBuilder |
ParallelClient.prepareUdp(java.lang.String command)
Prepare a parallel UDP Task.
|
ParallelTaskBuilder |
ParallelTaskBuilder.saveResponseHeaders(ResponseHeaderMeta responseHeaderMeta)
Sets the HTTP response header meta data.
|
ParallelTaskBuilder |
ParallelTaskBuilder.setAsyncHttpClient(com.ning.http.client.AsyncHttpClient asyncHttpClient)
Sets the async http client.
|
ParallelTaskBuilder |
ParallelTaskBuilder.setAutoSaveLogToLocal(boolean autoSaveLogToLocal)
Sets the auto save log to local.
|
ParallelTaskBuilder |
ParallelTaskBuilder.setConcurrency(int concurrency)
Sets the max concurrency.
|
ParallelTaskBuilder |
ParallelTaskBuilder.setConfig(ParallelTaskConfig config)
Sets the config.
|
ParallelTaskBuilder |
ParallelTaskBuilder.setEnableCapacityAwareTaskScheduler(boolean enableCapacityAwareTaskScheduler)
Sets the enable capacity aware task scheduler.
|
ParallelTaskBuilder |
ParallelTaskBuilder.setHttpEntityBody(java.lang.String body)
Sets the body.
|
ParallelTaskBuilder |
ParallelTaskBuilder.setHttpHeaders(ParallecHeader pheader)
this will create the adhoc header.
|
ParallelTaskBuilder |
ParallelTaskBuilder.setHttpPollable(boolean isPollable)
Sets the HTTP pollable.
|
ParallelTaskBuilder |
ParallelTaskBuilder.setHttpPollerProcessor(HttpPollerProcessor httpPollerProcessor)
Sets the HTTP poller processor to handle Async API.
|
ParallelTaskBuilder |
ParallelTaskBuilder.setHttpPort(int port)
Sets the port.
|
ParallelTaskBuilder |
ParallelTaskBuilder.setHttpPortReplaceable(java.lang.String portVar)
Sets the port variable name such as $PORT.
|
ParallelTaskBuilder |
ParallelTaskBuilder.setPingMode(PingMode mode)
Sets the ping mode.
|
ParallelTaskBuilder |
ParallelTaskBuilder.setPingNumRetries(int numRetries)
Sets the ping num retries.
|
ParallelTaskBuilder |
ParallelTaskBuilder.setPingTimeoutMillis(int pingTimeoutMillis)
Sets the ping timeout millis.
|
ParallelTaskBuilder |
ParallelTaskBuilder.setProtocol(RequestProtocol protocol)
Sets the protocol.
|
ParallelTaskBuilder |
ParallelTaskBuilder.setReplacementVarMap(java.util.Map<java.lang.String,java.lang.String> replacementVarMap)
Sets the replacement var map.
|
ParallelTaskBuilder |
ParallelTaskBuilder.setReplacementVarMapNodeSpecific(java.util.Map<java.lang.String,StrStrMap> replacementVarMapNodeSpecific)
Sets the replacement var map node specific.
|
ParallelTaskBuilder |
ParallelTaskBuilder.setReplaceVarMapToSingleTarget(java.util.List<StrStrMap> replacementVarMapList,
java.lang.String uniformTargetHost)
Sets the replace var map to single target.
|
ParallelTaskBuilder |
ParallelTaskBuilder.setReplaceVarMapToSingleTargetFromMap(java.util.Map<java.lang.String,StrStrMap> replacementVarMapNodeSpecific,
java.lang.String uniformTargetHost)
Sets the replace var map to single target from map.
|
ParallelTaskBuilder |
ParallelTaskBuilder.setReplaceVarMapToSingleTargetSingleVar(java.lang.String variable,
java.util.List<java.lang.String> replaceList,
java.lang.String uniformTargetHost)
Sets the replace var map to single target single var.
|
ParallelTaskBuilder |
ParallelTaskBuilder.setRequestReplacementType(RequestReplacementType requestReplacementType)
Sets the request replacement type.
|
ParallelTaskBuilder |
ParallelTaskBuilder.setResponseContext(java.util.Map<java.lang.String,java.lang.Object> responseContext)
Sets the response context.
|
ParallelTaskBuilder |
ParallelTaskBuilder.setRunAsSuperUser(java.lang.Boolean runAsSuperUser)
Sets the ssh runAsSuperUser.
|
ParallelTaskBuilder |
ParallelTaskBuilder.setSaveResponseToTask(boolean saveResponseToTask)
Sets the save response to task.
|
ParallelTaskBuilder |
ParallelTaskBuilder.setSshCommandLine(java.lang.String commandLine)
Sets the ssh command line.
|
ParallelTaskBuilder |
ParallelTaskBuilder.setSshConnectionTimeoutMillis(int sshConnectionTimeoutMillis)
Sets the ssh connection timeout millis.
|
ParallelTaskBuilder |
ParallelTaskBuilder.setSshLoginType(SshLoginType sshLoginType)
Sets the ssh login type.
|
ParallelTaskBuilder |
ParallelTaskBuilder.setSshPassword(java.lang.String password)
Sets the ssh password.
|
ParallelTaskBuilder |
ParallelTaskBuilder.setSshPort(int sshPort)
Sets the ssh port.
|
ParallelTaskBuilder |
ParallelTaskBuilder.setSshPrivKeyRelativePath(java.lang.String privKeyRelativePath)
Sets the ssh priv key relative path.
|
ParallelTaskBuilder |
ParallelTaskBuilder.setSshPrivKeyRelativePathWtihPassphrase(java.lang.String privKeyRelativePath,
java.lang.String passphrase)
Sets the ssh priv key relative path wtih passphrase.
|
ParallelTaskBuilder |
ParallelTaskBuilder.setSshUserName(java.lang.String userName)
Sets the ssh user name.
|
ParallelTaskBuilder |
ParallelTaskBuilder.setTargetHostsFromCmsQueryUrl(java.lang.String cmsQueryUrl)
Sets the target hosts from cms query url.
|
ParallelTaskBuilder |
ParallelTaskBuilder.setTargetHostsFromCmsQueryUrl(java.lang.String cmsQueryUrl,
java.lang.String projection)
CMS: configuration-management-service.
|
ParallelTaskBuilder |
ParallelTaskBuilder.setTargetHostsFromJsonPath(java.lang.String jsonPath,
java.lang.String sourcePath,
HostsSourceType sourceType)
Sets the target hosts from json path.
|
ParallelTaskBuilder |
ParallelTaskBuilder.setTargetHostsFromLineByLineText(java.lang.String sourcePath,
HostsSourceType sourceType)
Sets the target hosts from line by line text.
|
ParallelTaskBuilder |
ParallelTaskBuilder.setTargetHostsFromList(java.util.List<java.lang.String> targetHosts)
Sets the target hosts from list.
|
ParallelTaskBuilder |
ParallelTaskBuilder.setTargetHostsFromString(java.lang.String targetHostsStr)
Sets the target hosts from string.
|
ParallelTaskBuilder |
ParallelTaskBuilder.setTcpChannelFactory(org.jboss.netty.channel.ChannelFactory channelFactory)
Sets the tcp channel factory.
|
ParallelTaskBuilder |
ParallelTaskBuilder.setTcpConnectTimeoutMillis(int tcpConnectTimeoutMillis)
Sets the tcp connect timeout millis.
|
ParallelTaskBuilder |
ParallelTaskBuilder.setTcpIdleTimeoutSec(int tcpIdleTimeoutSec)
Sets the tcp idle timeout sec.
|
ParallelTaskBuilder |
ParallelTaskBuilder.setTcpPort(int tcpPort)
Sets the tcp port.
|
ParallelTaskBuilder |
ParallelTaskBuilder.setUdpIdleTimeoutSec(int udpIdleTimeoutSec)
Sets the udp read(idle) timeout millis.
|
ParallelTaskBuilder |
ParallelTaskBuilder.setUdpPort(int udpPort)
Sets the udp port.
|
ParallelTaskBuilder |
ParallelTaskBuilder.sync()
Execute the task synchronously (the default run mode).
|