Struct TimeBarAggregator

pub struct TimeBarAggregator<H>
where
    H: FnMut(Bar),
{ /* private fields */ }

Provides a means of building time bars aggregated from quote and trades.

At each aggregation time interval, a bar is created and sent to the handler.

Implementations

impl<H> TimeBarAggregator<H>

where H: FnMut(Bar) + 'static,

pub fn new( bar_type: BarType, price_precision: u8, size_precision: u8, clock: Rc<RefCell<dyn Clock>>, handler: H, await_partial: bool, build_with_no_updates: bool, timestamp_on_close: bool, interval_type: BarIntervalType, time_bars_origin: Option<DateTime<Utc>>, composite_bar_build_delay: i32, ) -> Self

Creates a new TimeBarAggregator instance.

Panics

This function panics:

• If instrument.id is not equal to the bar_type.instrument_id.
• If bar_type.aggregation_source is not equal to AggregationSource::Internal.

pub fn start(&mut self, callback: NewBarCallback<H>) -> Result<()>

Starts the time bar aggregator.

pub fn stop(&mut self)

Stops the time bar aggregator.

pub fn start_batch_time(&mut self, time_ns: UnixNanos)

Trait Implementations

impl<H> BarAggregator for TimeBarAggregator<H>

where H: FnMut(Bar) + 'static,

fn bar_type(&self) -> BarType

The [BarType] to be aggregated.

fn is_running(&self) -> bool

If the aggregator is running and will receive data from the message bus.

fn set_await_partial(&mut self, value: bool)

fn set_is_running(&mut self, value: bool)

fn update(&mut self, price: Price, size: Quantity, ts_event: UnixNanos)

Updates theaggregator with the given price and size.

fn update_bar(&mut self, bar: Bar, volume: Quantity, ts_init: UnixNanos)

fn start_batch_update(&mut self, handler: Box<dyn FnMut(Bar)>)

fn stop_batch_update(&mut self)

fn handle_quote(&mut self, quote: QuoteTick)

Updates the aggregator with the given quote.

fn handle_trade(&mut self, trade: TradeTick)

Updates the aggregator with the given trade.

fn handle_bar(&mut self, bar: Bar)