Struct ObserverProgressProjection 

pub struct ObserverProgressProjection { /* private fields */ }

Move-only exact observer-progress projection emitted by a committed source.

Participant acknowledgement and binding-ending transitions own the progress value. Consuming code can persist and publish this projection but cannot construct one from a guessed maximum or record-delivery observation.

use liminal_protocol::lifecycle::ObserverProgressProjection;

fn require_clone<T: Clone>() {}
require_clone::<ObserverProgressProjection>();

Implementations

impl ObserverProgressProjection

pub const fn conversation_id(&self) -> ConversationId

Returns the conversation whose hard observer progress may advance.

pub const fn new_observer_progress(&self) -> DeliverySeq

Returns the exact protocol-produced hard observer progress.

impl ObserverProgressProjection

pub fn encode_checkpoint(&self) -> [u8; 16]

Borrows the source conversation and exact hard progress into canonical bytes.

pub fn restore_checkpoint( body: &[u8], source: Self, ) -> Result<Self, OwnerCheckpointRestoreError>

Reassociates saved bytes with their protocol-produced committed source.

The validated source moves into the result; this does not mint a projection.

Errors

Refuses any framing, conversation, or exact progress mismatch.

Trait Implementations

impl Debug for ObserverProgressProjection

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

Formats the value using the given formatter.

impl Eq for ObserverProgressProjection

impl PartialEq for ObserverProgressProjection

fn eq(&self, other: &Self) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.