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: DateTime<Utc>)

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.

Panics

Panics if the RwLock is poisoned (should never happen in practice).

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<DateTime<Utc>>

Returns the timestamp of the most recent block.

Panics

Panics if the RwLock is poisoned (should never happen in practice).

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.

Panics

Panics if the RwLock is poisoned (should never happen in practice).

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<DateTime<Utc>>

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.

Panics

Panics if the RwLock is poisoned (should never happen in practice).

pub fn sample_count(&self) -> usize

Returns the number of samples collected in the rolling window.

Panics

Panics if the RwLock is poisoned (should never happen in practice).

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.