Struct RealtimePreflight 

pub struct RealtimePreflight {

    pub command_queue_depth: usize,
    pub command_queue_capacity: usize,
    pub observe_queue_depth: usize,
    pub observe_queue_capacity: usize,
    pub has_snapshot: bool,
    pub latest_snapshot_tick_id: u64,
    pub snapshot_age_ticks: u64,
    pub ring_capacity: usize,
    pub ring_len: usize,
    pub ring_write_pos: u64,
    pub ring_oldest_retained_pos: Option<u64>,
    pub ring_eviction_events: u64,
    pub ring_stale_read_events: u64,
    pub ring_skew_retry_events: u64,
    pub tick_thread_stopped: bool,
}

Non-blocking visibility snapshot for realtime health checks.

Fields

command_queue_depth: usize

Pending command batches in the ingress channel.

command_queue_capacity: usize

Ingress channel capacity (0 if unavailable/shut down).

observe_queue_depth: usize

Pending observation tasks in the egress task channel.

observe_queue_capacity: usize

Egress task channel capacity (0 if unavailable/shut down).

has_snapshot: bool

Whether a snapshot is currently available to serve observes.

latest_snapshot_tick_id: u64

Tick ID of the latest snapshot (0 when unavailable).

snapshot_age_ticks: u64

Snapshot age in ticks relative to the current epoch.

ring_capacity: usize

Ring retention capacity (maximum number of retained snapshots).

ring_len: usize

Current retained snapshot count.

ring_write_pos: u64

Current monotonic ring write position.

ring_oldest_retained_pos: Option<u64>

Oldest retained write position (None when ring is empty).

ring_eviction_events: u64

Cumulative count of evictions from ring overwrite.

ring_stale_read_events: u64

Cumulative count of stale/not-yet-written position reads.

ring_skew_retry_events: u64

Cumulative count of overwrite-skew retry events.

tick_thread_stopped: bool

Whether the tick thread has already stopped.

Trait Implementations

impl Clone for RealtimePreflight

fn clone(&self) -> RealtimePreflight

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for RealtimePreflight

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

Formats the value using the given formatter.

impl PartialEq for RealtimePreflight

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

impl Eq for RealtimePreflight

impl StructuralPartialEq for RealtimePreflight