Struct BlockTimeMonitor 

pub struct BlockTimeMonitor { /* private fields */ }

Monitors block times and provides estimation utilities for order expiration.

Thread-safe component that tracks rolling average block times from WebSocket data. Uses atomic operations for the hot path (height reads) and a read-write lock for less frequent operations (window updates, time estimation).

Implementations

impl BlockTimeMonitor

pub fn new() -> Self

Creates a new BlockTimeMonitor with default window size.

pub fn with_window_size(window_size: usize) -> Self

Creates a new BlockTimeMonitor with custom window size.

pub fn record_block(&self, height: u64, time: Timestamp)

Records a new block from WebSocket data.

Should be called whenever a block height update is received. Updates the current height atomically and adds the sample to the rolling window.

pub fn current_block_height(&self) -> u64

Returns the current block height.

This is a fast, lock-free read suitable for hot paths.

pub fn current_block_time(&self) -> Option<Timestamp>

Returns the timestamp of the most recent block.

pub fn estimated_seconds_per_block(&self) -> Option<f64>

Returns the estimated seconds per block based on rolling average.

Returns None if fewer than MIN_SAMPLES_FOR_ESTIMATE samples are available.

pub fn seconds_per_block_or_default(&self) -> f64

Returns estimated seconds per block, falling back to default if unavailable.

Uses DEFAULT_BLOCK_TIME_MS (500ms) when insufficient samples.

pub fn estimate_blocks_for_duration(&self, duration_secs: f64) -> u32

Estimates how many blocks will occur in the given duration.

Uses the rolling average if available, otherwise falls back to default block time. Result is capped at u32::MAX to prevent overflow from edge cases.

pub fn estimate_expiry_time(&self, expiry_block: u64) -> Option<Timestamp>

Estimates the wall-clock time when a specific block height will be reached.

Returns None if:

• Insufficient samples for reliable estimation
• No current block time available
• Target block is in the past

pub fn estimate_remaining_lifetime_secs(&self, expiry_block: u64) -> Option<f64>

Estimates remaining lifetime in seconds for an order expiring at the given block.

Returns None if insufficient data or block already passed.

pub fn is_ready(&self) -> bool

Returns true if the monitor has enough samples for reliable estimation.

pub fn sample_count(&self) -> usize

Returns the number of samples collected in the rolling window.

Trait Implementations

impl Debug for BlockTimeMonitor

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

Formats the value using the given formatter.

impl Default for BlockTimeMonitor

fn default() -> Self

Returns the “default value” for a type.