Enum ProcMessage

pub enum ProcMessage {
    Joined(),
    State {
        ret: OncePortRef<ProcState>,
    },
    Spawn {
        actor_type: String,
        actor_name: String,
        params_data: Data,
        status_port: PortRef<Index>,
    },
    SpawnProc {
        env: Environment,
        world_id: WorldId,
        proc_ids: Vec<ProcId>,
        world_size: usize,
    },
    UpdateSupervision(),
    Stop {
        timeout: Duration,
        reply_to: OncePortRef<ProcStopResult>,
    },
    Snapshot {
        reply_to: OncePortRef<ProcSnapshot>,
    },
    LocalAddr {
        reply_to: OncePortRef<ChannelAddr>,
    },
    PySpyDump {
        config: PySpyConfig,
        reply_to: OncePortRef<StackTrace>,
    },
}

Proc management messages.

Variants

Joined()

Indicate that the proc has joined the system. This is sent by the system actor when the proc has been registered and is ready to receive instructions.

State

Retrieve the state of the proc.

Fields

ret: OncePortRef<ProcState>

Used to return the result of the caller.

Spawn

Spawn an actor on the proc to the provided name.

Fields

actor_type: String

registered actor type

actor_name: String

spawned actor name

params_data: Data

serialized parameters

status_port: PortRef<Index>

reply port; the proc should send its rank to indicate a spawned actor

SpawnProc

Spawn a set of proc actors in the specified world (never its own)

Fields

env: Environment

Spawn the proc locally or in a separate program.

world_id: WorldId

The world into which to spawn the procs.

proc_ids: Vec<ProcId>

The proc ids of the procs to spawn.

world_size: usize

The total number of procs in the specified world.

UpdateSupervision()

Self message to trigger a supervision update to the system actor.

Stop

Stop the proc. Returns a pair of counts:

• the number of actors observed to stop;
• the number of proc actors not observed to stop.

There will be at least one actor (the proc-actor itself) that will be not observed to stop. If there is more than one timeouts are indicated.

Fields

timeout: Duration

The duration to wait for an actor to report status Stopped.

reply_to: OncePortRef<ProcStopResult>

Used to return the result to the caller.

Snapshot

Return a snapshot view of this proc. Used for debugging.

Fields

reply_to: OncePortRef<ProcSnapshot>

Used to return the result of the caller.

LocalAddr

Get the proc local addr.

Fields

reply_to: OncePortRef<ChannelAddr>

Used to return the result of the caller.

PySpyDump

Run pyspy on the current proc and return the stack trace.

Fields

config: PySpyConfig

Dump config.

reply_to: OncePortRef<StackTrace>

Used to return the result of the caller.

Trait Implementations

impl Clone for ProcMessage

fn clone(&self) -> ProcMessage

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for ProcMessage

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for ProcMessage

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Handler<ProcMessage> for ProcActor

fn handle<'life0, 'life1, 'async_trait>( &'life0 mut self, cx: &'life1 Context<'_, Self>, message: ProcMessage, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Handle the next M-typed message.

impl Named for ProcMessage

fn typename() -> &'static str

The globally unique type name for the type. This should typically be the fully qualified Rust name of the type.

fn typehash() -> u64

A globally unique hash for this type. TODO: actually enforce perfect hashing

fn arm(&self) -> Option<&'static str>

If the named type is an enum, this returns the name of the arm of the value self.

fn typeid() -> TypeId

The TypeId for this type. TypeIds are unique only within a binary, and should not be used for global identification.

fn port() -> u64

The globally unique port for this type. Typed ports are in the range of 1<<63..1<<64-1.

unsafe fn arm_unchecked(self_: *const ()) -> Option<&'static str>

An unsafe version of ‘arm’, accepting a pointer to the value, for use in type-erased settings.

impl PartialEq for ProcMessage

fn eq(&self, other: &ProcMessage) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Serialize for ProcMessage

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl RemoteHandles<ProcMessage> for ProcActor

impl StructuralPartialEq for ProcMessage