Struct MeshFailure 

pub struct MeshFailure {
    pub actor_mesh_name: Option<String>,
    pub event: ActorSupervisionEvent,
    pub crashed_ranks: Vec<usize>,
    pub reporting_controller: Option<ActorId>,
}

Message about a supervision failure on a mesh of actors instead of a single actor.

Fields

actor_mesh_name: Option<String>

Mesh name carried by the MeshFailure construction site, when locally available. On the direct actor-handled path this is the failed member’s recorded data mesh id. On controller-owned paths this is the monitored mesh name supplied by the controller path.

event: ActorSupervisionEvent

The supervision event on an actor located at mesh + rank.

crashed_ranks: Vec<usize>

The set of crashed ranks in the mesh. Empty means the event applies to the whole mesh (e.g. mesh stop, controller timeout).

reporting_controller: Option<ActorId>

Identity of the mesh controller that reported this failure, when one did (MFCA-3, MFCA-4). A separate role from event.actor_id (the event subject); the two may hold the same ActorId on a controller-originated event. None on construction paths with no reporting controller, which carry no controller attribution.

Implementations

impl MeshFailure

pub fn contains_rank(&self, rank: usize) -> bool

Returns true if the given rank is part of this failure. A whole-mesh event (empty crashed_ranks) contains every rank.

pub fn default_handler(&self, cx: &impl Actor) -> Result<(), Error>

Helper function to handle a message to an actor that just wants to forward it to the next owner.

Trait Implementations

impl Accepts<MeshFailure> for GlobalClientActor

where MeshFailure: RemoteMessage,

impl Accepts<MeshFailure> for WrapperActor

where MeshFailure: RemoteMessage,

impl Clone for MeshFailure

fn clone(&self) -> MeshFailure

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for MeshFailure

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for MeshFailure

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Display for MeshFailure

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

Formats the value using the given formatter.

impl Handler<MeshFailure> for GlobalClientActor

MeshFailure is a terminal supervision signal for an ActorMesh.

The process-global root client should never be a consumer of mesh-level supervision failures during normal operation: those events are expected to be observed and handled by the owning mesh/controller, not by the global client.

In processes that create and destroy multiple meshes (e.g., benchmarks), MeshFailure events may arrive here during or after mesh teardown. Log loudly but do not crash — the global client is a monitor and must preserve forward progress.

fn handle<'life0, 'life1, 'async_trait>( &'life0 mut self, _cx: &'life1 Context<'_, Self>, message: MeshFailure, ) -> 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.

fn message_status_reporting() -> MessageStatusReporting

Select which layer reports the message’s terminal telemetry status.

impl Handler<MeshFailure> for WrapperActor

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

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

Handle the next M-typed message.

fn message_status_reporting() -> MessageStatusReporting

Select which layer reports the message’s terminal telemetry status.

impl Named for MeshFailure

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.

impl PartialEq for MeshFailure

fn eq(&self, other: &MeshFailure) -> 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 RemoteHandles<MeshFailure> for GlobalClientActor

where MeshFailure: RemoteMessage,

impl RemoteHandles<MeshFailure> for WrapperActor

where MeshFailure: RemoteMessage,

impl Serialize for MeshFailure

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

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for MeshFailure