Package | Description |
---|---|
io.parallec.core |
Main package, including most user-facing classes such as the ParallelClient,
ParallelTask etc.
|
io.parallec.core.actor |
Actors to execute parallel task and return responses.
|
io.parallec.core.bean |
Beans.
|
io.parallec.core.task |
Modifier and Type | Field and Description |
---|---|
private TcpMeta |
ParallelTask.tcpMeta
The TCP meta.
|
private TcpMeta |
ParallelTaskBuilder.tcpMeta
The TCP request meta data.
|
Modifier and Type | Method and Description |
---|---|
TcpMeta |
ParallelTask.getTcpMeta()
Gets the tcp meta.
|
TcpMeta |
ParallelTaskBuilder.getTcpMeta()
Gets the tcp meta.
|
Modifier and Type | Method and Description |
---|---|
void |
ParallelTask.setTcpMeta(TcpMeta tcpMeta)
Sets the tcp meta.
|
void |
ParallelTaskBuilder.setTcpMeta(TcpMeta tcpMeta)
Sets the tcp meta.
|
Constructor and Description |
---|
ParallelTask(RequestProtocol requestProtocol,
int concurrency,
HttpMeta httpMeta,
TargetHostMeta targetHostMeta,
SshMeta sshMeta,
TcpMeta tcpMeta,
UdpMeta udpMeta,
PingMeta pingMeta,
ParallecResponseHandler handler,
java.util.Map<java.lang.String,java.lang.Object> responseContext,
java.util.Map<java.lang.String,StrStrMap> replacementVarMapNodeSpecific,
java.util.Map<java.lang.String,java.lang.String> replacementVarMap,
RequestReplacementType requestReplacementType,
ParallelTaskConfig config)
Instantiates a new parallel task.
|
Modifier and Type | Field and Description |
---|---|
private TcpMeta |
TcpWorker.tcpMeta
The tcp meta.
|
Constructor and Description |
---|
TcpWorker(int actorMaxOperationTimeoutSec,
TcpMeta tcpMeta,
java.lang.String targetHost)
Instantiates a new tcp worker.
|
Modifier and Type | Field and Description |
---|---|
private TcpMeta |
TaskRequest.tcpMeta
The tcp meta.
|
Modifier and Type | Method and Description |
---|---|
TcpMeta |
TaskRequest.getTcpMeta()
Gets the tcp meta.
|
Constructor and Description |
---|
TaskRequest(int actorMaxOperationTimeoutSec,
RequestProtocol protocol,
java.lang.String host,
java.lang.String hostUniform,
int port,
java.lang.String resourcePath,
java.lang.String requestContent,
HttpMethod httpMethod,
boolean pollable,
java.util.Map<java.lang.String,java.lang.String> httpHeaderMap,
ParallecResponseHandler handler,
java.util.Map<java.lang.String,java.lang.Object> responseContext,
SshMeta sshMeta,
TcpMeta tcpMeta,
UdpMeta udpMeta,
PingMeta pingMeta,
ResponseHeaderMeta responseHeaderMeta)
Instantiates a new task request.
|
Modifier and Type | Field and Description |
---|---|
private TcpMeta |
ParallelTaskBean.tcpMeta
The ssh meta.
|
Modifier and Type | Method and Description |
---|---|
TcpMeta |
ParallelTaskBean.getTcpMeta() |
Modifier and Type | Method and Description |
---|---|
void |
ParallelTaskBean.setTcpMeta(TcpMeta tcpMeta) |