Package | Description |
---|---|
groovyx.gpars.actor.impl |
This package holds classes some non-public aspects of actor implementation.
|
groovyx.gpars.actor.remote | |
groovyx.gpars.agent.remote | |
groovyx.gpars.dataflow.expression | |
groovyx.gpars.dataflow.stream | |
groovyx.gpars.remote |
This package holds classes implementing the remoting interface for actors, dataflows and agents.
|
groovyx.gpars.remote.message |
This package holds message classes for the remote actors implementation.
|
groovyx.gpars.remote.netty |
This package holds implementation-specific classes implementing the remote actors functionality on top of Netty.
|
groovyx.gpars.serial |
This package holds classes used for actor identification in the network.
|
Modifier and Type | Class and Description |
---|---|
static class |
MessageStream.SendTo |
Modifier and Type | Class and Description |
---|---|
static class |
RemoteActor.StopActorMsg |
static class |
RemoteActor.TerminateActorMsg |
Modifier and Type | Method and Description |
---|---|
<T> SerialMsg |
AgentClosureExecutionPolicy.prepareGetValMessage(RemoteAgent<T> agent,
DataflowVariable<T> resultVariable) |
abstract SerialMsg |
AgentClosureExecutionPolicy.prepareMessage(RemoteAgent<?> agent,
java.lang.Object message) |
Modifier and Type | Class and Description |
---|---|
static class |
DataflowExpression.BindDataflow<T>
Represents a remote message binding a value to a remoted DataflowExpression
|
Modifier and Type | Class and Description |
---|---|
private class |
DataflowStreamWriteAdapter.BindDataflowStream<T> |
Modifier and Type | Method and Description |
---|---|
private void |
LocalHost.createRequest(java.lang.String host,
int port,
SerialMsg msg) |
protected <T> DataflowVariable<T> |
LocalHost.getPromise(java.util.concurrent.ConcurrentMap<java.lang.String,DataflowVariable<T>> registry,
java.lang.String name,
java.lang.String host,
int port,
SerialMsg requestMsg) |
abstract void |
RemoteConnection.write(SerialMsg msg) |
void |
RemoteHost.write(SerialMsg msg) |
Modifier and Type | Class and Description |
---|---|
class |
CloseConnectionMsg
Message that triggers disconnect action.
|
class |
HostIdMsg
Message sent by NetTransportProvider immediately after connection to another host is set up
|
class |
RemoteActorReplyMsg
Message used to carry Actor.
|
class |
RemoteActorRequestMsg
Message used to carry remote Actor request.
|
class |
RemoteAgentGetValMsg<T>
Message that carry current state of Agent
|
class |
RemoteAgentReplyMsg
Message that carry Actor.
|
class |
RemoteAgentRequestMsg
Message that carry remote Agent request.
|
class |
RemoteAgentSendClosureMessage<T>
Message used to perform local closure execution.
|
class |
RemoteAgentSendMessage
Message that carry message to Agent.
|
class |
RemoteDataflowBroadcastReplyMsg
Message used to carry Broadcast stream.
|
class |
RemoteDataflowBroadcastRequestMsg
Message that carry Broadcast stream request.
|
class |
RemoteDataflowQueueEnqueueValueMsg<T>
Message that pushes new value into remote queue.
|
class |
RemoteDataflowQueueReplyMsg
Message that carry DataflowQueue.
|
class |
RemoteDataflowQueueRequestMsg
Message that carry remote Queue request.
|
class |
RemoteDataflowQueueValueRequestMsg<T>
Message that carry item request to remote queue.
|
class |
RemoteDataflowVariableReplyMsg
Message that carry Variable.
|
class |
RemoteDataflowVariableRequestMsg
Message that carry remote Variable request.
|
Modifier and Type | Method and Description |
---|---|
void |
NettyRemoteConnection.write(SerialMsg msg) |
Modifier and Type | Class and Description |
---|---|
static class |
SerialHandle.RemoteSerialHandle.ReleaseHandle |
Modifier and Type | Method and Description |
---|---|
abstract void |
SerialContext.write(SerialMsg msg) |