Struct FillTracker 

pub struct FillTracker { /* private fields */ }

Tracks cumulative fill state per bet to compute incremental fills from the Betfair OCM stream.

Betfair provides cumulative sm (size matched) and avp (average price matched) on each order update. This tracker maintains per-bet state to derive individual fill quantities and prices for each update.

Implementations

impl FillTracker

pub fn new() -> Self

Creates a new FillTracker instance.

pub fn maybe_fill_report( &mut self, uo: &UnmatchedOrder, order_qty: Decimal, instrument_id: InstrumentId, account_id: AccountId, currency: Currency, ts_event: UnixNanos, ts_init: UnixNanos, ) -> Option<FillReport>

Computes an incremental [FillReport] for an unmatched order update.

Returns None if no new fill occurred (size matched unchanged, duplicate trade ID, or overfill detected).

pub fn sync_order(&mut self, bet_id: &str, filled_qty: Decimal, avg_px: Decimal)

Pre-populates state for a bet from existing order data.

Monotonic in filled_qty: keeps the larger of the cached and in-memory values so a cache that lags the tracker (engine has not yet processed an emitted fill) cannot regress it.

pub fn seed_published_trade_ids<I, S>(&mut self, trade_ids: I)

where I: IntoIterator<Item = S>, S: Into<String>,

Seeds the trade-id dedup set so fills already published via another channel are not re-emitted when the post-reconnect image arrives.

pub fn prune(&mut self, bet_id: &str)

Removes state for a completed bet to prevent unbounded growth.

Trait Implementations

impl Debug for FillTracker

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

Formats the value using the given formatter.

impl Default for FillTracker

fn default() -> FillTracker

Returns the “default value” for a type.