Struct PartitionCommunicationAuthority 

pub struct PartitionCommunicationAuthority { /* private fields */ }

Cloneable bounded-completion and poison authority for one selected communication session.

Backend-owned operations adjacent to the neutral partition driver must retain this authority instead of a bare native group. Every clone observes the first terminal communication failure and fails before later submission.

Implementations

impl PartitionCommunicationAuthority

pub fn from_manifest( manifest: &CommunicationManifest, ) -> Result<Self, PartitionExecutionError>

Creates the poison and bounded-completion authority selected by one manifest.

pub fn ensure_active(&self) -> Result<(), PartitionExecutionError>

Rejects work after any submission, completion, cancellation, or deadline failure.

pub const fn completion_policy(&self) -> Option<CommunicationCompletionPolicy>

Returns the bounded completion policy selected by the communication manifest.

pub fn submission_error( &self, error: impl Display, operation: CommunicationOperation, phase: DistributedExecutionPhase, route: Option<CommunicationRouteId>, ) -> PartitionExecutionError

Records a native submission failure after preflight admission succeeded.

pub fn completion_error( &self, error: impl Display, operation: CommunicationOperation, phase: DistributedExecutionPhase, route: Option<CommunicationRouteId>, ) -> PartitionExecutionError

Records an exact native completion failure in the shared poison domain.

pub fn wait<T, C>( &self, submission: Submission<T, C>, operation: CommunicationOperation, phase: DistributedExecutionPhase, route: Option<CommunicationRouteId>, ) -> Result<T, PartitionExecutionError>

where C: BoundedCompletion, C::Error: Display,

Waits under the selected bound and permanently poisons this session on failure.

Trait Implementations

impl Clone for PartitionCommunicationAuthority

fn clone(&self) -> PartitionCommunicationAuthority

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for PartitionCommunicationAuthority

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

Formats the value using the given formatter.