Struct OptionChainManager 

pub struct OptionChainManager { /* private fields */ }

Per-series option chain manager.

Each instance manages a single option series: its aggregator, handlers, timer, and lifecycle. The DataEngine holds one manager per active series.

Implementations

impl OptionChainManager

pub fn all_instrument_ids(&self) -> Vec<InstrumentId>

Returns all instrument IDs in the full catalog (not just the active set).

pub fn venue(&self) -> Venue

Returns the venue for this option chain.

pub fn teardown(&mut self, clock: &Rc<RefCell<dyn Clock>>)

Tears down this manager: unregisters all msgbus handlers and cancels the timer.

pub fn handle_greeks(&mut self, greeks: &OptionGreeks)

Routes incoming greeks to the aggregator.

Also updates the ATM tracker from the forward price if ForwardPrice source is active, and triggers deferred bootstrap on the first arrival.

pub fn handle_instrument_expired( &mut self, instrument_id: &InstrumentId, ) -> bool

Handles an expired/settled instrument by removing it from the aggregator, unregistering msgbus handlers, and pushing deferred wire unsubscribes.

Returns true if the aggregator catalog is now empty (all instruments expired), signaling the engine to tear down this entire manager.

pub fn handle_quote(&mut self, quote: &QuoteTick)

Routes an incoming quote tick to the aggregator, then bootstraps if ready.

This handles both option instrument quotes (aggregator) and ATM source quotes (the aggregator’s ATM tracker handles filtering internally).

pub fn add_instrument( &mut self, instrument_id: InstrumentId, strike: Price, kind: OptionKind, client: Option<&mut DataClientAdapter>, clock: &Rc<RefCell<dyn Clock>>, ) -> bool

Adds a dynamically discovered instrument to this option chain.

Registers msgbus handlers when the instrument falls in the active range and forwards wire-level subscriptions via client. Returns true if the instrument was newly inserted.

pub fn publish_slice(&mut self, ts: UnixNanos)

Takes the accumulated snapshot and publishes it to the msgbus.

Trait Implementations

impl Debug for OptionChainManager

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

Formats the value using the given formatter.