Struct DeliveryReducer 

pub struct DeliveryReducer;

Stateless durable-delivery reducer.

Implementations

impl DeliveryReducer

pub fn claim( intents: Vec<DeliveryIntentSnapshot>, lease_id: String, ) -> Result<DeliveryClaim, SoftchatError>

Claim a bounded prefix of pending or retryable intents.

Errors

Returns a stable delivery error for malformed rows, a reused lease, or a first payload that cannot fit the claim profile.

pub fn mark_socket_written( claim: &DeliveryClaim, intent_ids: Vec<String>, ) -> Result<Vec<DeliveryStateMutation>, SoftchatError>

Mark an exact subset of one lease as socket-written.

Errors

Returns a stable delivery error for stale leases, duplicate IDs, or rows that were not in the claimed state.

pub fn apply_relay_results( claim: &DeliveryClaim, results: Vec<RelayDeliveryResult>, ) -> Result<Vec<DeliveryStateMutation>, SoftchatError>

Apply stable per-intent relay outcomes after a socket write.

Errors

Returns a stable delivery error for stale leases, duplicate/unknown IDs, invalid categories, or contradictory terminal transitions.

pub fn release_claim( claim: &DeliveryClaim, ) -> Result<Vec<DeliveryStateMutation>, SoftchatError>

Return every unfinished row in a lease to the retry queue.

Errors

Returns a stable delivery error for an invalid claim.

pub fn operation_snapshot( intents: Vec<DeliveryIntentSnapshot>, ) -> Result<OperationSnapshot, SoftchatError>

Derive one user-visible operation snapshot from durable intent rows.

Errors

Returns a stable operation error for empty or mixed-operation input.

Trait Implementations

impl Clone for DeliveryReducer

fn clone(&self) -> DeliveryReducer

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for DeliveryReducer

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

Formats the value using the given formatter.

impl Default for DeliveryReducer

fn default() -> DeliveryReducer

Returns the “default value” for a type.

impl Copy for DeliveryReducer