Struct CompletionFences 

pub struct CompletionFences { /* private fields */ }

Process-incarnation registry of the only generations allowed to complete.

Recovery deliberately starts with an empty registry. Re-dispatch issues a fresh token, so a result carrying any pre-recovery token is refused whether it arrives before or after the new dispatch.

Implementations

impl CompletionFences

pub fn issue( &self, workflow_id: &WorkflowId, activity_id: &ActivityId, ) -> Result<CompletionToken, ServerError>

Supersede any prior generation and return the newly authorized token.

Errors

Returns ServerError::LockPoisoned when fence state cannot be trusted.

pub fn accept( &self, workflow_id: &WorkflowId, activity_id: &ActivityId, submitted: &CompletionToken, ) -> Result<(), ServerError>

Consume the current generation only when submitted exactly matches it.

Consumption and comparison share one mutex critical section, making two concurrent submissions unable to both become truth.

Errors

Returns a typed rejection for a missing/current-generation mismatch, or ServerError::LockPoisoned when fence state cannot be trusted.

pub fn revoke( &self, workflow_id: &WorkflowId, activity_id: &ActivityId, token: &CompletionToken, ) -> Result<(), ServerError>

Revoke token if it is still current, without disturbing a newer retry.

Errors

Returns ServerError::LockPoisoned when fence state cannot be trusted.

pub fn revoke_current( &self, workflow_id: &WorkflowId, activity_id: &ActivityId, ) -> Result<(), ServerError>

Revoke whichever generation is current while parking for recovery.

Errors

Returns ServerError::LockPoisoned when fence state cannot be trusted.

Trait Implementations

impl Clone for CompletionFences

fn clone(&self) -> CompletionFences

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for CompletionFences

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

Formats the value using the given formatter.

impl Default for CompletionFences

fn default() -> CompletionFences

Returns the “default value” for a type.