Struct ReplayBuffer 

pub struct ReplayBuffer { /* private fields */ }

A circular buffer that stores recent trades and provides replay functionality

Implementations

impl ReplayBuffer

pub fn new(capacity: Duration) -> Self

Create a new replay buffer with the specified capacity

pub fn push(&self, trade: AggTrade)

Add a new trade to the buffer

pub fn len(&self) -> usize

Get the number of trades currently in the buffer

pub fn is_empty(&self) -> bool

Check if the buffer is empty

pub fn time_span(&self) -> Option<Duration>

Get the time span of trades in the buffer

pub fn get_trades_from(&self, minutes_ago: u32) -> Vec<AggTrade>

Get trades from the buffer starting from N minutes ago

pub fn replay_from( &self, minutes_ago: u32, speed_multiplier: f32, ) -> ReplayStream

Create a replay stream that emits trades at the specified speed

pub fn stats(&self) -> ReplayBufferStats

Get statistics about the buffer

Trait Implementations

impl Clone for ReplayBuffer

fn clone(&self) -> ReplayBuffer

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ReplayBuffer

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

Formats the value using the given formatter.