Struct ReceiptStreamCursorV1 

pub struct ReceiptStreamCursorV1 {
    pub subscription_id_hash: [u8; 16],
    pub receipt_kind_hash: [u8; 16],
    pub hlc_wall_ms: u64,
    pub position: PositionKind,
}

Versioned opaque receipt-stream cursor owned by syncbat.

Fields

subscription_id_hash: [u8; 16]

Route binding hash for the subscription id.

receipt_kind_hash: [u8; 16]

Route binding hash for the receipt kind filter.

hlc_wall_ms: u64

Visible HLC wall milliseconds at the cursor point (metadata).

position: PositionKind

Commit-order resume position encoded by the cursor.

Implementations

impl ReceiptStreamCursorV1

pub fn beginning(subscription_id: &str, receipt_kind: &str) -> Self

Encode the receipt-stream origin cursor for a route.

pub fn after_global_sequence( subscription_id: &str, receipt_kind: &str, global_sequence: u64, hlc_wall_ms: u64, ) -> Self

Encode a resume cursor strictly after global_sequence.

pub fn resume_after_global_sequence(&self) -> Option<u64>

Return the exclusive lower bound for query_entries_after, if any.

pub fn encode(&self) -> [u8; 56]

Encode to fixed 56-byte big-endian layout.

pub fn decode(bytes: &[u8]) -> Result<Self, SubscriptionRuntimeError>

Decode fixed-layout receipt-stream cursor bytes.

Errors

SubscriptionRuntimeError::CursorInvalid.

pub fn validate_route( &self, subscription_id: &str, receipt_kind: &str, ) -> Result<(), SubscriptionRuntimeError>

Validate cursor binding against a receipt-stream subscription route.

Errors

SubscriptionRuntimeError::CursorMismatch.

Trait Implementations

impl Clone for ReceiptStreamCursorV1

fn clone(&self) -> ReceiptStreamCursorV1

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ReceiptStreamCursorV1

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

Formats the value using the given formatter.

impl Eq for ReceiptStreamCursorV1

impl PartialEq for ReceiptStreamCursorV1

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