Trait OrderWriter 

pub trait OrderWriter: OrderReader {
    // Required methods
    fn persist_order_info_sync(&self, info: &PersistOrderInfo) -> Result<()>;
    fn persist_order_action_sync(
        &self,
        action: &PersistOrderAction,
    ) -> Result<()>;
    fn persist_order_update_sync(
        &self,
        update: &OrderUpdateMessage,
    ) -> Result<()>;
    fn persist_fill_with_side_effects_sync(
        &self,
        fill: &Fill,
        side_effects: &FillSideEffects,
    ) -> Result<(bool, bool)>;
    fn batch_cancel_orders_for_settlement_sync(
        &self,
        order_ids: &[i64],
        timestamp_ms: i64,
    ) -> Result<usize>;
    fn cancel_orphaned_orders_by_symbols_sync(
        &self,
        symbols: &[String],
    ) -> Result<usize>;
}

Order mutations.

Required Methods

fn persist_order_info_sync(&self, info: &PersistOrderInfo) -> Result<()>

Persist static order info (upsert on order_id).

fn persist_order_action_sync(&self, action: &PersistOrderAction) -> Result<()>

Persist an order action audit trail entry.

fn persist_order_update_sync(&self, update: &OrderUpdateMessage) -> Result<()>

Persist an order status update + materialize into order_infos.

fn persist_fill_with_side_effects_sync( &self, fill: &Fill, side_effects: &FillSideEffects, ) -> Result<(bool, bool)>

Persist a fill atomically with trades + ledger side effects.

fn batch_cancel_orders_for_settlement_sync( &self, order_ids: &[i64], timestamp_ms: i64, ) -> Result<usize>

Batch cancel orders for settlement.

fn cancel_orphaned_orders_by_symbols_sync( &self, symbols: &[String], ) -> Result<usize>

Cancel orphaned orders by symbol.

Implementors