Struct StreamHealth 

pub struct StreamHealth { /* private fields */ }

Tracks slot continuity, gaps, and freshness of incoming updates.

Implementations

impl StreamHealth

pub fn new() -> Self

pub fn record_update(&mut self, slot: u64) -> bool

Returns true if this update revealed a slot gap.

pub fn is_stale(&self, max_age: Duration) -> bool

pub fn last_slot(&self) -> u64

pub fn total_gaps(&self) -> u64

pub fn total_updates(&self) -> u64

pub fn max_observed_gap(&self) -> u64

pub fn consecutive_clean(&self) -> u64

pub fn gap_rate(&self) -> f64

Examples found in repository

examples/basic_stream.rs (line 35)

fn main() -> Result<(), Box<dyn std::error::Error>> {
    // No logger init — keeps example dependency-free.
    // The crate uses `log` facade; to see internal logs, add env_logger
    // (or any log backend) to your binary's Cargo.toml and init here.

    let api_key = std::env::var("HELIUS_API_KEY")
        .map_err(|_| "set HELIUS_API_KEY in environment")?;

    let config = StreamConfig::mainnet(api_key);
    let mut stream = HeliusStream::connect(config)?;

    println!("[INIT] subscribing to USDC mint");
    stream.subscribe_account_b58(USDC_MINT)?;

    let mut received = 0;
    while let Some(update) = stream.next_update() {
        received += 1;
        println!(
            "[UPDATE] slot={} lamports={} data_bytes={} safe={} gap_rate={:.3}",
            update.slot,
            update.lamports,
            update.data.len(),
            stream.is_safe_for_simulation(),
            stream.health().gap_rate(),
        );
        if received >= 10 {
            println!("[DONE] received 10 updates, exiting");
            break;
        }
    }
    Ok(())
}

pub fn last_update(&self) -> Instant

Trait Implementations

impl Debug for StreamHealth

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

Formats the value using the given formatter.

impl Default for StreamHealth

fn default() -> Self

Returns the “default value” for a type.