Struct DeriveExecutionClient 

pub struct DeriveExecutionClient { /* private fields */ }

Live execution client for Derive.

Owns the HTTP and WebSocket clients used to talk to the venue plus an ExecutionEventEmitter that publishes order/account events back to the live engine. Order operations are signed against the per-environment EIP-712 signing context resolved at construction.

Implementations

impl DeriveExecutionClient

pub fn new( core: ExecutionClientCore, config: DeriveExecClientConfig, ) -> Result<Self>

Creates a new DeriveExecutionClient.

Resolves wallet/session-key/subaccount from the supplied config, falling back to the documented environment variables when fields are unset, and parses the EIP-712 signing constants (domain separator, action typehash, trade-module address) from config overrides or the shipped per-environment defaults.

Errors

Returns an error when:

• Required credentials are not provided via config or environment.
• Signing constants are still placeholders or cannot be parsed as hex.
• The HTTP or WebSocket client cannot be constructed.

pub const fn subaccount_id(&self) -> u64

Returns the resolved subaccount id.

pub fn config(&self) -> &DeriveExecClientConfig

Returns a reference to the resolved configuration.

pub fn http_client(&self) -> &DeriveHttpClient

Returns a reference to the underlying HTTP client.

pub fn cache_instrument(&self, instrument: DeriveInstrument)

Caches a Derive instrument by instrument ID so order submission can resolve base_asset_address and base_asset_sub_id without re-querying the venue.

Trait Implementations

impl Debug for DeriveExecutionClient

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

Formats the value using the given formatter.

impl ExecutionClient for DeriveExecutionClient

fn is_connected(&self) -> bool

fn client_id(&self) -> ClientId

fn account_id(&self) -> AccountId

fn venue(&self) -> Venue

fn oms_type(&self) -> OmsType

fn get_account(&self) -> Option<AccountAny>

fn start(&mut self) -> Result<()>

Starts the execution client.

fn stop(&mut self) -> Result<()>

Stops the execution client.

fn connect<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = Result<()>> + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Connects the client to the execution venue.

fn disconnect<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = Result<()>> + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Disconnects the client from the execution venue.

fn generate_account_state( &self, balances: Vec<AccountBalance>, margins: Vec<MarginBalance>, reported: bool, ts_event: UnixNanos, ) -> Result<()>

Generates and publishes the account state event.

fn on_instrument(&mut self, _instrument: InstrumentAny)

Handles an instrument update received via the message bus.

fn generate_order_status_report<'life0, 'life1, 'async_trait>( &'life0 self, cmd: &'life1 GenerateOrderStatusReport, ) -> Pin<Box<dyn Future<Output = Result<Option<OrderStatusReport>>> + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Generates a single order status report.

fn generate_order_status_reports<'life0, 'life1, 'async_trait>( &'life0 self, cmd: &'life1 GenerateOrderStatusReports, ) -> Pin<Box<dyn Future<Output = Result<Vec<OrderStatusReport>>> + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Generates multiple order status reports.

fn generate_fill_reports<'life0, 'async_trait>( &'life0 self, cmd: GenerateFillReports, ) -> Pin<Box<dyn Future<Output = Result<Vec<FillReport>>> + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Generates fill reports based on execution results.

fn generate_position_status_reports<'life0, 'life1, 'async_trait>( &'life0 self, cmd: &'life1 GeneratePositionStatusReports, ) -> Pin<Box<dyn Future<Output = Result<Vec<PositionStatusReport>>> + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Generates position status reports.

fn generate_mass_status<'life0, 'async_trait>( &'life0 self, lookback_mins: Option<u64>, ) -> Pin<Box<dyn Future<Output = Result<Option<ExecutionMassStatus>>> + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Generates mass status for executions.

fn submit_order(&self, cmd: SubmitOrder) -> Result<()>

Submits a single order command to the execution venue.

fn submit_order_list(&self, cmd: SubmitOrderList) -> Result<()>

Submits a list of orders to the execution venue.

fn cancel_order(&self, cmd: CancelOrder) -> Result<()>

Cancels a specific order.

fn cancel_all_orders(&self, cmd: CancelAllOrders) -> Result<()>

Cancels all orders.

fn batch_cancel_orders(&self, cmd: BatchCancelOrders) -> Result<()>

Cancels a batch of orders.

fn modify_order(&self, cmd: ModifyOrder) -> Result<()>

Modifies an existing order.

fn query_account(&self, _cmd: QueryAccount) -> Result<()>

Queries the status of an account.

fn query_order(&self, cmd: QueryOrder) -> Result<()>

Queries the status of an order.

fn handles_order_venue(&self, venue: Venue) -> bool

Returns whether this client can execute orders for the given instrument venue.

fn reset(&mut self) -> Result<(), Error>

Resets the execution client to its initial state.

fn dispose(&mut self) -> Result<(), Error>

Disposes of client resources and cleans up.

fn register_external_order( &self, _client_order_id: ClientOrderId, _venue_order_id: VenueOrderId, _instrument_id: InstrumentId, _strategy_id: StrategyId, _ts_init: UnixNanos, )

Registers an external order for tracking by the execution client.

fn calculate_commission( &self, instrument: &InstrumentAny, last_qty: Quantity, last_px: Price, liquidity_side: LiquiditySide, ) -> Option<Money>

Calculates the commission for a reconciliation fill.