Struct StreamLease 

pub struct StreamLease {
    pub id: u64,
    pub lease_handle: String,
    pub snapshot_lsn: u64,
    pub opened_at_ms: u64,
    pub config: StreamConfig,
}

Fields

id: u64

lease_handle: String

Issue #767 / S8 — opaque handle handed to the client. 32-char hex (128 bits of CSPRNG output). The internal id is not derivable from this value.

snapshot_lsn: u64

opened_at_ms: u64

config: StreamConfig

Implementations

impl StreamLease

pub fn snapshot_expired(&self, now_ms: u64) -> bool

true once snapshot_ttl_ms has elapsed since the lease was opened. The shim slice materialises the result first, so expiry in practice only fires for streams that take longer than ttl_ms to drain to the client. The check is wired in so the wire envelope can carry snapshot_expired exactly the way later slices (pull-based executors) will need it.

Trait Implementations

impl Debug for StreamLease

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

Formats the value using the given formatter.