Struct MutationIntent 

pub struct MutationIntent { /* private fields */ }

In-memory intent that must be durably inserted before acknowledgement.

Implementations

impl MutationIntent

pub const fn new( operation_id: OperationId, idempotency_key: IdempotencyKey, origin: MutationOrigin, session_generation: SessionGeneration, desired: DesiredMutation, preconditions: MutationPreconditions, ) -> Self

Creates an intent. Call Self::validate_for_persistence before durable insertion.

pub fn with_local_content(self, local_content: LocalContentSnapshot) -> Self

Attaches an owned local-content reference.

pub fn with_platform_correlation( self, platform_correlation: PlatformRequestCorrelation, ) -> Self

Attaches an owned platform correlation token.

pub fn with_remote_reconciliation_key( self, remote_reconciliation_key: RemoteReconciliationKey, ) -> Self

Attaches a backend status/change-feed reconciliation key.

pub fn with_retry(self, retry: MutationRetryMetadata) -> Self

Replaces persisted retry metadata.

pub fn validate_for_persistence(&self) -> Result<()>

Validates invariants needed before the intent becomes recoverable.

Errors

Returns an error when validation fails or an underlying backend, store, or platform operation fails.

pub const fn operation_id(&self) -> &OperationId

Returns the operation identity.

pub const fn idempotency_key(&self) -> &IdempotencyKey

Returns the backend idempotency key.

pub const fn origin(&self) -> MutationOrigin

Returns how the mutation entered the shared mechanism.

pub const fn session_generation(&self) -> SessionGeneration

Returns the platform session generation captured by the intent.

pub const fn desired(&self) -> &DesiredMutation

Returns the desired product-neutral mutation.

pub const fn preconditions(&self) -> &MutationPreconditions

Returns independent metadata/content revision preconditions.

pub const fn local_content(&self) -> Option<&LocalContentSnapshot>

Returns the owned local-content reference, when needed.

pub const fn platform_correlation(&self) -> Option<&PlatformRequestCorrelation>

Returns the owned platform request correlation token.

pub const fn remote_reconciliation_key( &self, ) -> Option<&RemoteReconciliationKey>

Returns the remote status/change-feed reconciliation key.

pub const fn retry(&self) -> &MutationRetryMetadata

Returns persisted retry metadata.

Trait Implementations

impl Clone for MutationIntent

fn clone(&self) -> MutationIntent

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for MutationIntent

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

Formats the value using the given formatter.

impl PartialEq for MutationIntent

fn eq(&self, other: &MutationIntent) -> 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 Eq for MutationIntent

impl StructuralPartialEq for MutationIntent