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 maybe_fill_voids( &mut self, uo: &UnmatchedOrder, ) -> Vec<FillVoidAllocation>

Allocates cumulative Betfair sv to known applied fill lots, newest first.

First-seen voids without known fill lots are recorded but emit no correction.

pub fn has_unseen_fill_void(&self, uo: &UnmatchedOrder) -> bool

Returns whether a cumulative Betfair void update has not yet been applied.

pub fn has_unseen_fill(&self, uo: &UnmatchedOrder) -> bool

Returns whether a cumulative Betfair fill update has not yet been applied.

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 Clone for FillTracker

fn clone(&self) -> FillTracker

Returns a duplicate of the value.

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

Performs copy-assignment from source.

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.