Struct ActorMeshControlPlane 

pub struct ActorMeshControlPlane<A: Referable> { /* private fields */ }

Controller-side state for an actor mesh.

ActorMeshRef is moving toward being a self-contained, serializable mesh descriptor. The controller is the one place that needs both the actor mesh and its backing proc mesh: it streams actor state through proc agents and stops actors through the proc mesh control plane.

Trait Implementations

impl<A: Referable> Clone for ActorMeshControlPlane<A>

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<A: Referable> Controlled for ActorMeshControlPlane<A>

Controlled implementation for an actor mesh.

type StateInner = ActorState

Inner payload carried in resource::State<Self::StateInner>.

fn stall_counter() -> &'static Counter<u64>

Counter bumped when the supervision loop detects a stall.

fn id(&self) -> &ResourceId

The mesh’s resource identifier.

fn region(&self) -> &Region

The region of ranks in this mesh.

fn subscribe_to_stream( &self, cx: &impl Actor, subscriber: PortRef<State<ActorState>>, ) -> Result<()>

Subscribe the given port to StreamState<StateInner> updates from the underlying agents.

fn forward_wait_rank_status( &self, cx: &impl Actor, msg: WaitRankStatus, ) -> Result<()>

Forward a WaitRankStatus message to the underlying agents.

fn poll_states<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, cx: &'life1 (impl 'async_trait + Actor), supervision_display_name: &'life2 str, health_state: &'life3 mut HealthState, ) -> Pin<Box<dyn Future<Output = PollResult> + Send + 'async_trait>>

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

Mesh-specific polling step for the supervision loop. Implementations may do pre-checks (such as the actor mesh’s proc-aliveness check) before querying rank states; updates to health_state happen in-place. supervision_display_name is used for synthesised supervision events (e.g., when a proc dies).

fn process_state( &self, cx: &impl Actor, state: State<ActorState>, health_state: &mut HealthState, ) -> bool

Process a single streamed or polled state. Updates the health state and notifies owner/subscribers as appropriate. Returns true if a notification was emitted (used to suppress heartbeats).

fn handle_stop_request<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, cx: &'life1 (impl 'async_trait + Actor), _supervision_display_name: &'life2 str, reason: String, health_state: &'life3 mut HealthState, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Perform the mesh-specific stop: issue stop messages to the underlying agents and, where appropriate, update health_state and notify subscribers. The caller has already taken the monitor and logged.

fn cleanup_stop<'life0, 'life1, 'async_trait>( &'life0 self, cx: &'life1 (impl 'async_trait + Actor), reason: String, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Stop this mesh on controller cleanup (when Stop was not received but the actor is shutting down).

impl<A: Referable> Debug for ActorMeshControlPlane<A>

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

Formats the value using the given formatter.

impl<A: Referable> Named for ActorMeshControlPlane<A>

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 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

A globally unique numeric identifier for this type.

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

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

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.