Struct MockExchange

Source

pub struct MockExchange {
    pub exchange: ExchangeId,
    pub latency_ms: u64,
    pub fee_model: FeeModelConfig,
    pub fill_model: SimFillConfig,
    pub request_rx: UnboundedReceiver<MockExchangeRequest>,
    pub event_tx: Sender<UnindexedAccountEvent>,
    pub instruments: FnvHashMap<InstrumentNameExchange, Instrument<ExchangeId, AssetNameExchange>>,
    pub account: AccountState,
    pub order_sequence: u64,
    pub time_exchange_latest: DateTime<Utc>,
}

Fields§

§exchange: ExchangeId§latency_ms: u64§fee_model: FeeModelConfig§fill_model: SimFillConfig§request_rx: UnboundedReceiver<MockExchangeRequest>§event_tx: Sender<UnindexedAccountEvent>§instruments: FnvHashMap<InstrumentNameExchange, Instrument<ExchangeId, AssetNameExchange>>§account: AccountState§order_sequence: u64§time_exchange_latest: DateTime<Utc>

Struct MockExchange Copy item path

Fields§

Implementations§

impl MockExchange

pub fn new( config: MockExecutionConfig, request_rx: UnboundedReceiver<MockExchangeRequest>, event_tx: Sender<UnindexedAccountEvent>, instruments: FnvHashMap<InstrumentNameExchange, Instrument<ExchangeId, AssetNameExchange>>, ) -> Self

pub async fn run(self)

pub fn time_exchange(&self) -> DateTime<Utc>

pub fn account_snapshot(&self) -> UnindexedAccountSnapshot

pub fn account_stream(&self) -> BoxStream<'static, UnindexedAccountEvent>

pub fn cancel_order( &mut self, _: OrderRequestCancel<ExchangeId, InstrumentNameExchange>, ) -> Order<ExchangeId, InstrumentNameExchange, Result<Cancelled, UnindexedOrderError>>

pub fn open_order( &mut self, request: OrderRequestOpen<ExchangeId, InstrumentNameExchange>, market_prices: MarketPrices, ) -> (Order<ExchangeId, InstrumentNameExchange, UnindexedOrderState>, Option<OpenOrderNotifications>)

pub fn validate_order_kind_supported( &self, order_kind: OrderKind, ) -> Result<(), UnindexedOrderError>

pub fn find_instrument_data( &self, instrument: &InstrumentNameExchange, ) -> Result<&Instrument<ExchangeId, AssetNameExchange>, UnindexedApiError>

Trait Implementations§

impl Debug for MockExchange

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

Auto Trait Implementations§

impl Freeze for MockExchange

impl RefUnwindSafe for MockExchange

impl Send for MockExchange

impl Sync for MockExchange

impl Unpin for MockExchange

impl UnsafeUnpin for MockExchange

impl UnwindSafe for MockExchange

Blanket Implementations§

impl<T> Any for Twhere T: 'static + ?Sized,

fn type_id(&self) -> TypeId

impl<T> Borrow<T> for Twhere T: ?Sized,

fn borrow(&self) -> &T

impl<T> BorrowMut<T> for Twhere T: ?Sized,

fn borrow_mut(&mut self) -> &mut T

impl<T> From<T> for T

fn from(t: T) -> T

impl<T> Instrument for T

fn instrument(self, span: Span) -> Instrumented<Self>

fn in_current_span(self) -> Instrumented<Self>

impl<T, U> Into<U> for Twhere U: From<T>,

fn into(self) -> U

impl<T> IntoEither for T

fn into_either(self, into_left: bool) -> Either<Self, Self>

fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>where F: FnOnce(&Self) -> bool,

impl<T> PolicyExt for Twhere T: ?Sized,

fn and<P, B, E>(self, other: P) -> And<T, P>where T: Policy<B, E>, P: Policy<B, E>,

fn or<P, B, E>(self, other: P) -> Or<T, P>where T: Policy<B, E>, P: Policy<B, E>,

impl<T> Same for T

type Output = T

impl<T, U> TryFrom<U> for Twhere U: Into<T>,

type Error = Infallible

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

impl<T, U> TryInto<U> for Twhere U: TryFrom<T>,

type Error = <U as TryFrom<T>>::Error

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

impl<V, T> VZip<V> for Twhere V: MultiLane<T>,

fn vzip(self) -> V

impl<T> WithSubscriber for T

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>where S: Into<Dispatch>,

fn with_current_subscriber(self) -> WithDispatch<Self>

Struct MockExchange

impl<T> Any for T
where T: 'static + ?Sized,

impl<T> Borrow<T> for T
where T: ?Sized,

impl<T> BorrowMut<T> for T
where T: ?Sized,

impl<T, U> Into<U> for T
where U: From<T>,

fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
where F: FnOnce(&Self) -> bool,

impl<T> PolicyExt for T
where T: ?Sized,

fn and<P, B, E>(self, other: P) -> And<T, P>
where T: Policy<B, E>, P: Policy<B, E>,

fn or<P, B, E>(self, other: P) -> Or<T, P>
where T: Policy<B, E>, P: Policy<B, E>,

impl<T, U> TryFrom<U> for T
where U: Into<T>,

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

impl<V, T> VZip<V> for T
where V: MultiLane<T>,

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,