Skip to main content

LiveExecEngineConfigBuilder

nautilus_live::config

Struct LiveExecEngineConfigBuilder 

Source 
pub struct LiveExecEngineConfigBuilder<S: State = Empty> { /* private fields */ }
Expand description

Use builder syntax to set the inputs and finish with build().

Implementations§

Source§

impl<S: State> LiveExecEngineConfigBuilder<S>

Source

pub fn build(self) -> LiveExecEngineConfig
where S: IsComplete,

Finish building and return the requested object

Source

pub fn load_cache( self, value: bool, ) -> LiveExecEngineConfigBuilder<SetLoadCache<S>>
where S::LoadCache: IsUnset,

Optional (Some / Option setters). Default: true.

If the cache should be loaded on initialization.

Source

pub fn maybe_load_cache( self, value: Option<bool>, ) -> LiveExecEngineConfigBuilder<SetLoadCache<S>>
where S::LoadCache: IsUnset,

Optional (Some / Option setters). Default: true.

If the cache should be loaded on initialization.

Source

pub fn snapshot_orders( self, value: bool, ) -> LiveExecEngineConfigBuilder<SetSnapshotOrders<S>>
where S::SnapshotOrders: IsUnset,

Optional (Some / Option setters). Default: false.

If order state snapshot lists should be persisted to a backing database.

Not implemented on the current live runtime; validate_runtime_support rejects any value other than the default because the live kernel does not yet wire a cache database adapter.

Source

pub fn maybe_snapshot_orders( self, value: Option<bool>, ) -> LiveExecEngineConfigBuilder<SetSnapshotOrders<S>>
where S::SnapshotOrders: IsUnset,

Optional (Some / Option setters). Default: false.

If order state snapshot lists should be persisted to a backing database.

Not implemented on the current live runtime; validate_runtime_support rejects any value other than the default because the live kernel does not yet wire a cache database adapter.

Source

pub fn snapshot_positions( self, value: bool, ) -> LiveExecEngineConfigBuilder<SetSnapshotPositions<S>>
where S::SnapshotPositions: IsUnset,

Optional (Some / Option setters). Default: false.

If position state snapshot lists should be persisted to a backing database.

Not implemented on the current live runtime; validate_runtime_support rejects any value other than the default because the live kernel does not yet wire a cache database adapter.

Source

pub fn maybe_snapshot_positions( self, value: Option<bool>, ) -> LiveExecEngineConfigBuilder<SetSnapshotPositions<S>>
where S::SnapshotPositions: IsUnset,

Optional (Some / Option setters). Default: false.

If position state snapshot lists should be persisted to a backing database.

Not implemented on the current live runtime; validate_runtime_support rejects any value other than the default because the live kernel does not yet wire a cache database adapter.

Source

pub fn snapshot_positions_interval_secs( self, value: f64, ) -> LiveExecEngineConfigBuilder<SetSnapshotPositionsIntervalSecs<S>>
where S::SnapshotPositionsIntervalSecs: IsUnset,

Optional (Some / Option setters). The interval (seconds) at which additional position state snapshots are persisted. If None then no additional snapshots will be taken.

Source

pub fn maybe_snapshot_positions_interval_secs( self, value: Option<f64>, ) -> LiveExecEngineConfigBuilder<SetSnapshotPositionsIntervalSecs<S>>
where S::SnapshotPositionsIntervalSecs: IsUnset,

Optional (Some / Option setters). The interval (seconds) at which additional position state snapshots are persisted. If None then no additional snapshots will be taken.

Source

pub fn external_clients( self, value: Vec<ClientId>, ) -> LiveExecEngineConfigBuilder<SetExternalClients<S>>
where S::ExternalClients: IsUnset,

Optional (Some / Option setters). Client IDs declared for external stream processing.

The execution engine will not attempt to send trading commands to these client IDs, assuming an external process consumes them from the bus.

Source

pub fn maybe_external_clients( self, value: Option<Vec<ClientId>>, ) -> LiveExecEngineConfigBuilder<SetExternalClients<S>>
where S::ExternalClients: IsUnset,

Optional (Some / Option setters). Client IDs declared for external stream processing.

The execution engine will not attempt to send trading commands to these client IDs, assuming an external process consumes them from the bus.

Source

pub fn debug(self, value: bool) -> LiveExecEngineConfigBuilder<SetDebug<S>>
where S::Debug: IsUnset,

Optional (Some / Option setters). Default: false.

If debug mode is active (will provide extra debug logging).

Source

pub fn maybe_debug( self, value: Option<bool>, ) -> LiveExecEngineConfigBuilder<SetDebug<S>>
where S::Debug: IsUnset,

Optional (Some / Option setters). Default: false.

If debug mode is active (will provide extra debug logging).

Source

pub fn reconciliation( self, value: bool, ) -> LiveExecEngineConfigBuilder<SetReconciliation<S>>
where S::Reconciliation: IsUnset,

Optional (Some / Option setters). Default: true.

If reconciliation is active at start-up.

Source

pub fn maybe_reconciliation( self, value: Option<bool>, ) -> LiveExecEngineConfigBuilder<SetReconciliation<S>>
where S::Reconciliation: IsUnset,

Optional (Some / Option setters). Default: true.

If reconciliation is active at start-up.

Source

pub fn reconciliation_startup_delay_secs( self, value: f64, ) -> LiveExecEngineConfigBuilder<SetReconciliationStartupDelaySecs<S>>
where S::ReconciliationStartupDelaySecs: IsUnset,

Optional (Some / Option setters). Default: 10.0.

The delay (seconds) before starting reconciliation at startup.

Source

pub fn maybe_reconciliation_startup_delay_secs( self, value: Option<f64>, ) -> LiveExecEngineConfigBuilder<SetReconciliationStartupDelaySecs<S>>
where S::ReconciliationStartupDelaySecs: IsUnset,

Optional (Some / Option setters). Default: 10.0.

The delay (seconds) before starting reconciliation at startup.

Source

pub fn reconciliation_lookback_mins( self, value: u32, ) -> LiveExecEngineConfigBuilder<SetReconciliationLookbackMins<S>>
where S::ReconciliationLookbackMins: IsUnset,

Optional (Some / Option setters). The maximum lookback minutes to reconcile state for.

Source

pub fn maybe_reconciliation_lookback_mins( self, value: Option<u32>, ) -> LiveExecEngineConfigBuilder<SetReconciliationLookbackMins<S>>
where S::ReconciliationLookbackMins: IsUnset,

Optional (Some / Option setters). The maximum lookback minutes to reconcile state for.

Source

pub fn reconciliation_instrument_ids( self, value: Vec<String>, ) -> LiveExecEngineConfigBuilder<SetReconciliationInstrumentIds<S>>
where S::ReconciliationInstrumentIds: IsUnset,

Optional (Some / Option setters). Specific instrument IDs to reconcile (if None, reconciles all).

Source

pub fn maybe_reconciliation_instrument_ids( self, value: Option<Vec<String>>, ) -> LiveExecEngineConfigBuilder<SetReconciliationInstrumentIds<S>>
where S::ReconciliationInstrumentIds: IsUnset,

Optional (Some / Option setters). Specific instrument IDs to reconcile (if None, reconciles all).

Source

pub fn filter_unclaimed_external_orders( self, value: bool, ) -> LiveExecEngineConfigBuilder<SetFilterUnclaimedExternalOrders<S>>
where S::FilterUnclaimedExternalOrders: IsUnset,

Optional (Some / Option setters). Default: false.

If unclaimed order events with an EXTERNAL strategy ID should be filtered/dropped.

Source

pub fn maybe_filter_unclaimed_external_orders( self, value: Option<bool>, ) -> LiveExecEngineConfigBuilder<SetFilterUnclaimedExternalOrders<S>>
where S::FilterUnclaimedExternalOrders: IsUnset,

Optional (Some / Option setters). Default: false.

If unclaimed order events with an EXTERNAL strategy ID should be filtered/dropped.

Source

pub fn filter_position_reports( self, value: bool, ) -> LiveExecEngineConfigBuilder<SetFilterPositionReports<S>>
where S::FilterPositionReports: IsUnset,

Optional (Some / Option setters). Default: false.

If position status reports are filtered from reconciliation.

Source

pub fn maybe_filter_position_reports( self, value: Option<bool>, ) -> LiveExecEngineConfigBuilder<SetFilterPositionReports<S>>
where S::FilterPositionReports: IsUnset,

Optional (Some / Option setters). Default: false.

If position status reports are filtered from reconciliation.

Source

pub fn filtered_client_order_ids( self, value: Vec<String>, ) -> LiveExecEngineConfigBuilder<SetFilteredClientOrderIds<S>>
where S::FilteredClientOrderIds: IsUnset,

Optional (Some / Option setters). Client order IDs to filter from reconciliation.

Source

pub fn maybe_filtered_client_order_ids( self, value: Option<Vec<String>>, ) -> LiveExecEngineConfigBuilder<SetFilteredClientOrderIds<S>>
where S::FilteredClientOrderIds: IsUnset,

Optional (Some / Option setters). Client order IDs to filter from reconciliation.

Source

pub fn generate_missing_orders( self, value: bool, ) -> LiveExecEngineConfigBuilder<SetGenerateMissingOrders<S>>
where S::GenerateMissingOrders: IsUnset,

Optional (Some / Option setters). Default: true.

If MARKET order events will be generated during reconciliation to align discrepancies.

Source

pub fn maybe_generate_missing_orders( self, value: Option<bool>, ) -> LiveExecEngineConfigBuilder<SetGenerateMissingOrders<S>>
where S::GenerateMissingOrders: IsUnset,

Optional (Some / Option setters). Default: true.

If MARKET order events will be generated during reconciliation to align discrepancies.

Source

pub fn inflight_check_interval_ms( self, value: u32, ) -> LiveExecEngineConfigBuilder<SetInflightCheckIntervalMs<S>>
where S::InflightCheckIntervalMs: IsUnset,

Optional (Some / Option setters). Default: 2_000.

The interval (milliseconds) between checking whether in-flight orders have exceeded their threshold.

Source

pub fn maybe_inflight_check_interval_ms( self, value: Option<u32>, ) -> LiveExecEngineConfigBuilder<SetInflightCheckIntervalMs<S>>
where S::InflightCheckIntervalMs: IsUnset,

Optional (Some / Option setters). Default: 2_000.

The interval (milliseconds) between checking whether in-flight orders have exceeded their threshold.

Source

pub fn inflight_check_threshold_ms( self, value: u32, ) -> LiveExecEngineConfigBuilder<SetInflightCheckThresholdMs<S>>
where S::InflightCheckThresholdMs: IsUnset,

Optional (Some / Option setters). Default: 5_000.

The threshold (milliseconds) beyond which an in-flight order’s status is checked with the venue.

Source

pub fn maybe_inflight_check_threshold_ms( self, value: Option<u32>, ) -> LiveExecEngineConfigBuilder<SetInflightCheckThresholdMs<S>>
where S::InflightCheckThresholdMs: IsUnset,

Optional (Some / Option setters). Default: 5_000.

The threshold (milliseconds) beyond which an in-flight order’s status is checked with the venue.

Source

pub fn inflight_check_retries( self, value: u32, ) -> LiveExecEngineConfigBuilder<SetInflightCheckRetries<S>>
where S::InflightCheckRetries: IsUnset,

Optional (Some / Option setters). Default: 5.

The number of retry attempts for verifying in-flight order status.

Source

pub fn maybe_inflight_check_retries( self, value: Option<u32>, ) -> LiveExecEngineConfigBuilder<SetInflightCheckRetries<S>>
where S::InflightCheckRetries: IsUnset,

Optional (Some / Option setters). Default: 5.

The number of retry attempts for verifying in-flight order status.

Source

pub fn open_check_interval_secs( self, value: f64, ) -> LiveExecEngineConfigBuilder<SetOpenCheckIntervalSecs<S>>
where S::OpenCheckIntervalSecs: IsUnset,

Optional (Some / Option setters). The interval (seconds) between checks for open orders at the venue.

Source

pub fn maybe_open_check_interval_secs( self, value: Option<f64>, ) -> LiveExecEngineConfigBuilder<SetOpenCheckIntervalSecs<S>>
where S::OpenCheckIntervalSecs: IsUnset,

Optional (Some / Option setters). The interval (seconds) between checks for open orders at the venue.

Source

pub fn open_check_lookback_mins( self, value: u32, ) -> LiveExecEngineConfigBuilder<SetOpenCheckLookbackMins<S>>
where S::OpenCheckLookbackMins: IsUnset,

Optional (Some / Option setters). The lookback minutes for open order checks. When None, the check is unbounded (no time filter).

Source

pub fn maybe_open_check_lookback_mins( self, value: Option<u32>, ) -> LiveExecEngineConfigBuilder<SetOpenCheckLookbackMins<S>>
where S::OpenCheckLookbackMins: IsUnset,

Optional (Some / Option setters). The lookback minutes for open order checks. When None, the check is unbounded (no time filter).

Source

pub fn open_check_threshold_ms( self, value: u32, ) -> LiveExecEngineConfigBuilder<SetOpenCheckThresholdMs<S>>
where S::OpenCheckThresholdMs: IsUnset,

Optional (Some / Option setters). Default: 5_000.

The minimum elapsed time (milliseconds) since an order update before acting on discrepancies.

Source

pub fn maybe_open_check_threshold_ms( self, value: Option<u32>, ) -> LiveExecEngineConfigBuilder<SetOpenCheckThresholdMs<S>>
where S::OpenCheckThresholdMs: IsUnset,

Optional (Some / Option setters). Default: 5_000.

The minimum elapsed time (milliseconds) since an order update before acting on discrepancies.

Source

pub fn open_check_missing_retries( self, value: u32, ) -> LiveExecEngineConfigBuilder<SetOpenCheckMissingRetries<S>>
where S::OpenCheckMissingRetries: IsUnset,

Optional (Some / Option setters). Default: 5.

The number of retries for missing open orders.

Source

pub fn maybe_open_check_missing_retries( self, value: Option<u32>, ) -> LiveExecEngineConfigBuilder<SetOpenCheckMissingRetries<S>>
where S::OpenCheckMissingRetries: IsUnset,

Optional (Some / Option setters). Default: 5.

The number of retries for missing open orders.

Source

pub fn open_check_open_only( self, value: bool, ) -> LiveExecEngineConfigBuilder<SetOpenCheckOpenOnly<S>>
where S::OpenCheckOpenOnly: IsUnset,

Optional (Some / Option setters). Default: true.

If the check_open_orders requests only currently open orders from the venue.

Source

pub fn maybe_open_check_open_only( self, value: Option<bool>, ) -> LiveExecEngineConfigBuilder<SetOpenCheckOpenOnly<S>>
where S::OpenCheckOpenOnly: IsUnset,

Optional (Some / Option setters). Default: true.

If the check_open_orders requests only currently open orders from the venue.

Source

pub fn max_single_order_queries_per_cycle( self, value: u32, ) -> LiveExecEngineConfigBuilder<SetMaxSingleOrderQueriesPerCycle<S>>
where S::MaxSingleOrderQueriesPerCycle: IsUnset,

Optional (Some / Option setters). Default: 10.

The maximum number of single-order queries per consistency check cycle.

Source

pub fn maybe_max_single_order_queries_per_cycle( self, value: Option<u32>, ) -> LiveExecEngineConfigBuilder<SetMaxSingleOrderQueriesPerCycle<S>>
where S::MaxSingleOrderQueriesPerCycle: IsUnset,

Optional (Some / Option setters). Default: 10.

The maximum number of single-order queries per consistency check cycle.

Source

pub fn single_order_query_delay_ms( self, value: u32, ) -> LiveExecEngineConfigBuilder<SetSingleOrderQueryDelayMs<S>>
where S::SingleOrderQueryDelayMs: IsUnset,

Optional (Some / Option setters). Default: 100.

The delay (milliseconds) between consecutive single-order queries.

Source

pub fn maybe_single_order_query_delay_ms( self, value: Option<u32>, ) -> LiveExecEngineConfigBuilder<SetSingleOrderQueryDelayMs<S>>
where S::SingleOrderQueryDelayMs: IsUnset,

Optional (Some / Option setters). Default: 100.

The delay (milliseconds) between consecutive single-order queries.

Source

pub fn position_check_interval_secs( self, value: f64, ) -> LiveExecEngineConfigBuilder<SetPositionCheckIntervalSecs<S>>
where S::PositionCheckIntervalSecs: IsUnset,

Optional (Some / Option setters). The interval (seconds) between checks for open positions at the venue.

Source

pub fn maybe_position_check_interval_secs( self, value: Option<f64>, ) -> LiveExecEngineConfigBuilder<SetPositionCheckIntervalSecs<S>>
where S::PositionCheckIntervalSecs: IsUnset,

Optional (Some / Option setters). The interval (seconds) between checks for open positions at the venue.

Source

pub fn position_check_lookback_mins( self, value: u32, ) -> LiveExecEngineConfigBuilder<SetPositionCheckLookbackMins<S>>
where S::PositionCheckLookbackMins: IsUnset,

Optional (Some / Option setters). Default: 60.

The lookback minutes for position consistency checks.

Source

pub fn maybe_position_check_lookback_mins( self, value: Option<u32>, ) -> LiveExecEngineConfigBuilder<SetPositionCheckLookbackMins<S>>
where S::PositionCheckLookbackMins: IsUnset,

Optional (Some / Option setters). Default: 60.

The lookback minutes for position consistency checks.

Source

pub fn position_check_threshold_ms( self, value: u32, ) -> LiveExecEngineConfigBuilder<SetPositionCheckThresholdMs<S>>
where S::PositionCheckThresholdMs: IsUnset,

Optional (Some / Option setters). Default: 5_000.

The minimum elapsed time (milliseconds) since a position update before acting on discrepancies.

Source

pub fn maybe_position_check_threshold_ms( self, value: Option<u32>, ) -> LiveExecEngineConfigBuilder<SetPositionCheckThresholdMs<S>>
where S::PositionCheckThresholdMs: IsUnset,

Optional (Some / Option setters). Default: 5_000.

The minimum elapsed time (milliseconds) since a position update before acting on discrepancies.

Source

pub fn position_check_retries( self, value: u32, ) -> LiveExecEngineConfigBuilder<SetPositionCheckRetries<S>>
where S::PositionCheckRetries: IsUnset,

Optional (Some / Option setters). Default: 3.

The maximum number of reconciliation attempts for a position discrepancy.

Source

pub fn maybe_position_check_retries( self, value: Option<u32>, ) -> LiveExecEngineConfigBuilder<SetPositionCheckRetries<S>>
where S::PositionCheckRetries: IsUnset,

Optional (Some / Option setters). Default: 3.

The maximum number of reconciliation attempts for a position discrepancy.

Source

pub fn purge_closed_orders_interval_mins( self, value: u32, ) -> LiveExecEngineConfigBuilder<SetPurgeClosedOrdersIntervalMins<S>>
where S::PurgeClosedOrdersIntervalMins: IsUnset,

Optional (Some / Option setters). The interval (minutes) between purging closed orders from the in-memory cache.

Source

pub fn maybe_purge_closed_orders_interval_mins( self, value: Option<u32>, ) -> LiveExecEngineConfigBuilder<SetPurgeClosedOrdersIntervalMins<S>>
where S::PurgeClosedOrdersIntervalMins: IsUnset,

Optional (Some / Option setters). The interval (minutes) between purging closed orders from the in-memory cache.

Source

pub fn purge_closed_orders_buffer_mins( self, value: u32, ) -> LiveExecEngineConfigBuilder<SetPurgeClosedOrdersBufferMins<S>>
where S::PurgeClosedOrdersBufferMins: IsUnset,

Optional (Some / Option setters). The time buffer (minutes) before closed orders can be purged.

Source

pub fn maybe_purge_closed_orders_buffer_mins( self, value: Option<u32>, ) -> LiveExecEngineConfigBuilder<SetPurgeClosedOrdersBufferMins<S>>
where S::PurgeClosedOrdersBufferMins: IsUnset,

Optional (Some / Option setters). The time buffer (minutes) before closed orders can be purged.

Source

pub fn purge_closed_positions_interval_mins( self, value: u32, ) -> LiveExecEngineConfigBuilder<SetPurgeClosedPositionsIntervalMins<S>>
where S::PurgeClosedPositionsIntervalMins: IsUnset,

Optional (Some / Option setters). The interval (minutes) between purging closed positions from the in-memory cache.

Source

pub fn maybe_purge_closed_positions_interval_mins( self, value: Option<u32>, ) -> LiveExecEngineConfigBuilder<SetPurgeClosedPositionsIntervalMins<S>>
where S::PurgeClosedPositionsIntervalMins: IsUnset,

Optional (Some / Option setters). The interval (minutes) between purging closed positions from the in-memory cache.

Source

pub fn purge_closed_positions_buffer_mins( self, value: u32, ) -> LiveExecEngineConfigBuilder<SetPurgeClosedPositionsBufferMins<S>>
where S::PurgeClosedPositionsBufferMins: IsUnset,

Optional (Some / Option setters). The time buffer (minutes) before closed positions can be purged.

Source

pub fn maybe_purge_closed_positions_buffer_mins( self, value: Option<u32>, ) -> LiveExecEngineConfigBuilder<SetPurgeClosedPositionsBufferMins<S>>
where S::PurgeClosedPositionsBufferMins: IsUnset,

Optional (Some / Option setters). The time buffer (minutes) before closed positions can be purged.

Source

pub fn purge_account_events_interval_mins( self, value: u32, ) -> LiveExecEngineConfigBuilder<SetPurgeAccountEventsIntervalMins<S>>
where S::PurgeAccountEventsIntervalMins: IsUnset,

Optional (Some / Option setters). The interval (minutes) between purging account events from the in-memory cache.

Source

pub fn maybe_purge_account_events_interval_mins( self, value: Option<u32>, ) -> LiveExecEngineConfigBuilder<SetPurgeAccountEventsIntervalMins<S>>
where S::PurgeAccountEventsIntervalMins: IsUnset,

Optional (Some / Option setters). The interval (minutes) between purging account events from the in-memory cache.

Source

pub fn purge_account_events_lookback_mins( self, value: u32, ) -> LiveExecEngineConfigBuilder<SetPurgeAccountEventsLookbackMins<S>>
where S::PurgeAccountEventsLookbackMins: IsUnset,

Optional (Some / Option setters). The time buffer (minutes) before account events can be purged.

Source

pub fn maybe_purge_account_events_lookback_mins( self, value: Option<u32>, ) -> LiveExecEngineConfigBuilder<SetPurgeAccountEventsLookbackMins<S>>
where S::PurgeAccountEventsLookbackMins: IsUnset,

Optional (Some / Option setters). The time buffer (minutes) before account events can be purged.

Source

pub fn purge_from_database( self, value: bool, ) -> LiveExecEngineConfigBuilder<SetPurgeFromDatabase<S>>
where S::PurgeFromDatabase: IsUnset,

Optional (Some / Option setters). Default: false.

If purge operations should also delete from the backing database.

Source

pub fn maybe_purge_from_database( self, value: Option<bool>, ) -> LiveExecEngineConfigBuilder<SetPurgeFromDatabase<S>>
where S::PurgeFromDatabase: IsUnset,

Optional (Some / Option setters). Default: false.

If purge operations should also delete from the backing database.

Source

pub fn own_books_audit_interval_secs( self, value: f64, ) -> LiveExecEngineConfigBuilder<SetOwnBooksAuditIntervalSecs<S>>
where S::OwnBooksAuditIntervalSecs: IsUnset,

Optional (Some / Option setters). The interval (seconds) between auditing own books against public order books.

Source

pub fn maybe_own_books_audit_interval_secs( self, value: Option<f64>, ) -> LiveExecEngineConfigBuilder<SetOwnBooksAuditIntervalSecs<S>>
where S::OwnBooksAuditIntervalSecs: IsUnset,

Optional (Some / Option setters). The interval (seconds) between auditing own books against public order books.

Source

pub fn graceful_shutdown_on_error( self, value: bool, ) -> LiveExecEngineConfigBuilder<SetGracefulShutdownOnError<S>>
where S::GracefulShutdownOnError: IsUnset,

Optional (Some / Option setters). Default: false.

If the engine should gracefully shutdown when queue processing encounters unexpected errors.

Source

pub fn maybe_graceful_shutdown_on_error( self, value: Option<bool>, ) -> LiveExecEngineConfigBuilder<SetGracefulShutdownOnError<S>>
where S::GracefulShutdownOnError: IsUnset,

Optional (Some / Option setters). Default: false.

If the engine should gracefully shutdown when queue processing encounters unexpected errors.

Source

pub fn qsize(self, value: u32) -> LiveExecEngineConfigBuilder<SetQsize<S>>
where S::Qsize: IsUnset,

Optional (Some / Option setters). Default: 100_000.

The queue size for the engine’s internal queue buffers.

Source

pub fn maybe_qsize( self, value: Option<u32>, ) -> LiveExecEngineConfigBuilder<SetQsize<S>>
where S::Qsize: IsUnset,

Optional (Some / Option setters). Default: 100_000.

The queue size for the engine’s internal queue buffers.

Source

pub fn allow_overfills( self, value: bool, ) -> LiveExecEngineConfigBuilder<SetAllowOverfills<S>>
where S::AllowOverfills: IsUnset,

Optional (Some / Option setters). Default: false.

If order fills exceeding order quantity are allowed (logs warning instead of raising). Useful when position reconciliation races with exchange fill events.

Source

pub fn maybe_allow_overfills( self, value: Option<bool>, ) -> LiveExecEngineConfigBuilder<SetAllowOverfills<S>>
where S::AllowOverfills: IsUnset,

Optional (Some / Option setters). Default: false.

If order fills exceeding order quantity are allowed (logs warning instead of raising). Useful when position reconciliation races with exchange fill events.

Source

pub fn manage_own_order_books( self, value: bool, ) -> LiveExecEngineConfigBuilder<SetManageOwnOrderBooks<S>>
where S::ManageOwnOrderBooks: IsUnset,

Optional (Some / Option setters). Default: false.

If the execution engine should maintain own/user order books based on commands and events.

Source

pub fn maybe_manage_own_order_books( self, value: Option<bool>, ) -> LiveExecEngineConfigBuilder<SetManageOwnOrderBooks<S>>
where S::ManageOwnOrderBooks: IsUnset,

Optional (Some / Option setters). Default: false.

If the execution engine should maintain own/user order books based on commands and events.

Auto Trait Implementations§

Blanket Implementations§

Source§

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

Source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
Source§

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

Source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
Source§

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

Source§

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

Mutably borrows from an owned value. Read more
Source§

impl<T> From<T> for T

Source§

fn from(t: T) -> T

Returns the argument unchanged.

§

impl<T> Instrument for T

§

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

Instruments this type with the provided [Span], returning an Instrumented wrapper. Read more
§

fn in_current_span(self) -> Instrumented<Self>

Instruments this type with the current Span, returning an Instrumented wrapper. Read more
Source§

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

Source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Source§

impl<T> IntoEither for T

Source§

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

Converts self into a Left variant of Either<Self, Self> if into_left is true. Converts self into a Right variant of Either<Self, Self> otherwise. Read more
Source§

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

Converts self into a Left variant of Either<Self, Self> if into_left(&self) returns true. Converts self into a Right variant of Either<Self, Self> otherwise. Read more
§

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>,

Create a new Policy that returns [Action::Follow] only if self and other return Action::Follow. Read more
§

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

Create a new Policy that returns [Action::Follow] if either self or other returns Action::Follow. Read more
Source§

impl<T> Same for T

Source§

type Output = T

Should always be Self
Source§

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

Source§

type Error = Infallible

The type returned in the event of a conversion error.
Source§

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

Performs the conversion.
Source§

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

Source§

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

The type returned in the event of a conversion error.
Source§

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

Performs the conversion.
§

impl<V, T> VZip<V> for T
where 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>,

Attaches the provided Subscriber to this type, returning a [WithDispatch] wrapper. Read more
§

fn with_current_subscriber(self) -> WithDispatch<Self>

Attaches the current default Subscriber to this type, returning a [WithDispatch] wrapper. Read more
§

impl<T> Allocation for T
where T: RefUnwindSafe + Send + Sync,

§

impl<T> Ungil for T
where T: Send,