Enum ractor_cluster::node::NodeServerMessage

pub enum NodeServerMessage {
    ConnectionOpened {
        stream: TcpStream,
        is_server: bool,
    },
    CheckSession {
        peer_name: NameMessage,
        reply: RpcReplyPort<SessionCheckReply>,
    },
    UpdateSession {
        actor_id: ActorId,
        name: NameMessage,
    },
    GetSessions(RpcReplyPort<HashMap<NodeId, ActorRef<NodeSession>>>),
}

Messages to/from the session manager

Variants

ConnectionOpened

Fields

stream: TcpStream

The TcpStream for this network connection

is_server: bool

Flag denoting if it’s a server (incoming) connection when true, false for outgoing

Notifies the session manager that a new incoming (is_server = true) or outgoing (is_server = false) TcpStream was accepted

CheckSession

Fields

peer_name: NameMessage

The peer’s name to investigate

reply: RpcReplyPort<SessionCheckReply>

Reply channel for RPC

A request to check if a session is currently open, and if it is is the ordering such that we should reject the incoming request

i.e. if A is connected to B and A.name > B.name, but then B connects to A, B’s request to connect to A should be rejected

UpdateSession

Fields

actor_id: ActorId

The ID of the NodeSession actor

name: NameMessage

The node’s name (now that we’ve received it)

A request to update the session mapping with this now known node’s name

GetSessions(RpcReplyPort<HashMap<NodeId, ActorRef<NodeSession>>>)

Retrieve the current status of the node server, listing the node sessions

Trait Implementations

impl Message for NodeServerMessage

fn from_boxed(m: BoxedMessage) -> Result<Self, BoxedDowncastErr>

Convert a BoxedMessage to this concrete type

fn box_message(self, pid: &ActorId) -> Result<BoxedMessage, BoxedDowncastErr>

Convert this message to a BoxedMessage

fn serializable() -> bool

Determines if this type is serializable

fn serialize(self) -> Result<SerializedMessage, BoxedDowncastErr>

Serializes this message (if supported)

fn deserialize(bytes: SerializedMessage) -> Result<Self, BoxedDowncastErr>

Deserialize binary data to this message type