Enum EngineCommand 

pub enum EngineCommand {
    OrderAction(OrderActionMessage),
    MarketAction(MarketActionCommand),
    LiquidationState(LiquidationStateMessage),
    TickExpiry {
        now_ms: u64,
        context: TickExpiryContext,
    },
    TickSnapshot {
        now_ms: u64,
    },
    PriceUpdate {
        underlying: String,
        spot_price: Decimal,
        timestamp_ms: u64,
    },
    IvUpdate {
        underlying: String,
        surface: VolatilitySurface,
        journal_data: Option<Vec<u8>>,
        timestamp_ms: u64,
    },
    TierUpdate {
        wallet: WalletAddress,
        margin_mode: MarginMode,
        tier: String,
        trading_limits: TradingLimits,
    },
    LegacyTierMarginModeUpdate {
        wallet: WalletAddress,
        margin_mode: MarginMode,
    },
    HypercorePositionUpdate {
        account: String,
        coin: String,
        size: f64,
        entry_price: f64,
        unrealized_pnl: f64,
        timestamp_ms: u64,
    },
    MmpConfigUpdate {
        wallet: WalletAddress,
        currency: String,
        enabled: bool,
        interval_ms: i64,
        frozen_time_ms: i64,
        qty_limit: Option<f64>,
        delta_limit: Option<f64>,
        vega_limit: Option<f64>,
    },
    RfqExecute(RfqExecuteCommand),
    TradingModeUpdate {
        modes: HashMap<String, TradingModes>,
        timestamp_ms: u64,
    },
    DepositUpdate {
        wallet: WalletAddress,
        amount: Decimal,
        timestamp_ms: u64,
        sequence: Option<u64>,
        source_event_hash: FixedBytes<32>,
    },
    OptionDepositUpdate {
        request_id: String,
        wallet: WalletAddress,
        symbol: String,
        quantity: Decimal,
        timestamp_ms: u64,
    },
    OptionWithdrawalUpdate {
        request_id: String,
        wallet: WalletAddress,
        account: WalletAddress,
        signer: WalletAddress,
        rsm_signer: WalletAddress,
        symbol: String,
        quantity: Decimal,
        nonce: Option<u64>,
        action: Vec<u8>,
        timestamp_ms: u64,
    },
    CashWithdrawalUpdate {
        request_id: String,
        wallet: WalletAddress,
        account: WalletAddress,
        destination: WalletAddress,
        signer: WalletAddress,
        rsm_signer: WalletAddress,
        amount: Decimal,
        amount_wei: u64,
        nonce: Option<u64>,
        timestamp_ms: u64,
    },
    LiquidationBonusUpdate {
        wallet: WalletAddress,
        amount: Decimal,
        balance_after: Decimal,
        timestamp_ms: u64,
        sequence: Option<u64>,
    },
    ApproveAgent {
        wallet: WalletAddress,
        agent: WalletAddress,
        expires_at_ms: Option<u64>,
        nonce: Option<u64>,
        timestamp_ms: u64,
    },
    RevokeAgent {
        wallet: WalletAddress,
        agent: WalletAddress,
        nonce: Option<u64>,
        timestamp_ms: u64,
    },
    NonceAdvance {
        wallet: WalletAddress,
        nonce: u64,
        timestamp_ms: u64,
    },
    HypercoreEquityUpdate {
        wallet: WalletAddress,
        account_value: Decimal,
        timestamp_ms: u64,
    },
    SetPmSettlementPoolConfig(SetPmSettlementPoolConfigCommand),
    RecordPmVaultDeposit(RecordPmVaultDepositCommand),
    RequestPmVaultWithdrawal(RequestPmVaultWithdrawalCommand),
    AccruePmSettlementInterest(AccruePmSettlementInterestCommand),
    ApplyPmSettlementRepayment(ApplyPmSettlementRepaymentCommand),
    JournalPmRecoveryPlan(JournalPmRecoveryPlanCommand),
    MarkPmRecoveryActionSubmitted(MarkPmRecoveryActionSubmittedCommand),
    ResolvePmRecoveryAction(ResolvePmRecoveryActionCommand),
}

Commands that mutate engine state.

Every state-affecting input enters the engine as one of these variants. Commands are the sole mechanism for state change, making the engine fully deterministic: the same command sequence always produces the same state.

Commands arrive from multiple sources in the runtime:

• REST API handlers produce Order, MmpConfigUpdate, TierUpdate
• Oracle feeds produce PriceUpdate, IvUpdate
• On-chain event listeners produce DepositUpdate, HypercorePositionUpdate
• Timer ticks produce TickExpiry, TradingModeUpdate
• Liquidation monitor produces LiquidationState

Variants

OrderAction(OrderActionMessage)

MarketAction(MarketActionCommand)

LiquidationState(LiquidationStateMessage)

TickExpiry

Fields

now_ms: u64

context: TickExpiryContext

TickSnapshot

Fields

now_ms: u64

PriceUpdate

Fields

underlying: String

spot_price: Decimal

timestamp_ms: u64

IvUpdate

Fields

underlying: String

surface: VolatilitySurface

journal_data: Option<Vec<u8>>

timestamp_ms: u64

TierUpdate

Fields

wallet: WalletAddress

margin_mode: MarginMode

tier: String

trading_limits: TradingLimits

LegacyTierMarginModeUpdate

Fields

wallet: WalletAddress

margin_mode: MarginMode

HypercorePositionUpdate

Fields

account: String

coin: String

size: f64

entry_price: f64

unrealized_pnl: f64

timestamp_ms: u64

MmpConfigUpdate

Fields

wallet: WalletAddress

currency: String

enabled: bool

interval_ms: i64

frozen_time_ms: i64

qty_limit: Option<f64>

delta_limit: Option<f64>

vega_limit: Option<f64>

RfqExecute(RfqExecuteCommand)

TradingModeUpdate

Fields

modes: HashMap<String, TradingModes>

timestamp_ms: u64

DepositUpdate

Fields

wallet: WalletAddress

amount: Decimal

timestamp_ms: u64

sequence: Option<u64>

source_event_hash: FixedBytes<32>

OptionDepositUpdate

Fields

request_id: String

wallet: WalletAddress

symbol: String

quantity: Decimal

timestamp_ms: u64

OptionWithdrawalUpdate

Fields

request_id: String

wallet: WalletAddress

account: WalletAddress

signer: WalletAddress

rsm_signer: WalletAddress

symbol: String

quantity: Decimal

nonce: Option<u64>

action: Vec<u8>

timestamp_ms: u64

CashWithdrawalUpdate

Fields

request_id: String

wallet: WalletAddress

account: WalletAddress

destination: WalletAddress

signer: WalletAddress

rsm_signer: WalletAddress

amount: Decimal

amount_wei: u64

nonce: Option<u64>

timestamp_ms: u64

LiquidationBonusUpdate

Fields

wallet: WalletAddress

amount: Decimal

balance_after: Decimal

timestamp_ms: u64

sequence: Option<u64>

ApproveAgent

Fields

wallet: WalletAddress

agent: WalletAddress

expires_at_ms: Option<u64>

nonce: Option<u64>

timestamp_ms: u64

RevokeAgent

Fields

wallet: WalletAddress

agent: WalletAddress

nonce: Option<u64>

timestamp_ms: u64

NonceAdvance

Fields

wallet: WalletAddress

nonce: u64

timestamp_ms: u64

HypercoreEquityUpdate

Fields

wallet: WalletAddress

account_value: Decimal

timestamp_ms: u64

SetPmSettlementPoolConfig(SetPmSettlementPoolConfigCommand)

RecordPmVaultDeposit(RecordPmVaultDepositCommand)

RequestPmVaultWithdrawal(RequestPmVaultWithdrawalCommand)

AccruePmSettlementInterest(AccruePmSettlementInterestCommand)

ApplyPmSettlementRepayment(ApplyPmSettlementRepaymentCommand)

JournalPmRecoveryPlan(JournalPmRecoveryPlanCommand)

MarkPmRecoveryActionSubmitted(MarkPmRecoveryActionSubmittedCommand)

ResolvePmRecoveryAction(ResolvePmRecoveryActionCommand)

Implementations

impl EngineCommand

pub fn command_type(&self) -> &'static str

pub fn request_id(&self) -> Option<String>

pub fn wallet(&self) -> Option<&WalletAddress>

pub fn symbol(&self) -> Option<&str>

pub fn order_id(&self) -> Option<u64>

pub fn identity_hash(&self) -> [u8; 32]

Trait Implementations

impl Clone for EngineCommand

fn clone(&self) -> EngineCommand

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for EngineCommand

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

Formats the value using the given formatter.

impl<'a> RestartStateComponent<EngineRecoveryCapture<'a>, EngineCtx, EngineCommand, EngineStateDigest> for AuthNonceComponent

const NAME: RestartComponentName = RestartComponentName::AuthNonce

type Snapshot = EngineStateSnapshot

fn capture(ctx: &EngineRecoveryCapture<'a>) -> Self::Snapshot

fn restore(ctx: &mut EngineCtx, snapshot: &Self::Snapshot)

fn digest(ctx: &EngineRecoveryCapture<'a>) -> EngineStateDigest

fn replay(_command: &EngineCommand, _ctx: &mut EngineCtx) -> ReplayDisposition

fn mutation_sources() -> &'static [MutationSource]

fn descriptor() -> RestartComponentDescriptor

impl<'a> RestartStateComponent<EngineRecoveryCapture<'a>, EngineCtx, EngineCommand, EngineStateDigest> for CashLedgerComponent

const NAME: RestartComponentName = RestartComponentName::CashLedger

type Snapshot = EngineStateSnapshot

fn capture(ctx: &EngineRecoveryCapture<'a>) -> Self::Snapshot

fn restore(ctx: &mut EngineCtx, snapshot: &Self::Snapshot)

fn digest(ctx: &EngineRecoveryCapture<'a>) -> EngineStateDigest

fn replay(_command: &EngineCommand, _ctx: &mut EngineCtx) -> ReplayDisposition

fn mutation_sources() -> &'static [MutationSource]

fn descriptor() -> RestartComponentDescriptor

impl<'a> RestartStateComponent<EngineRecoveryCapture<'a>, EngineCtx, EngineCommand, EngineStateDigest> for HypercoreStateComponent

const NAME: RestartComponentName = RestartComponentName::HypercoreState

type Snapshot = EngineStateSnapshot

fn capture(ctx: &EngineRecoveryCapture<'a>) -> Self::Snapshot

fn restore(ctx: &mut EngineCtx, snapshot: &Self::Snapshot)

fn digest(ctx: &EngineRecoveryCapture<'a>) -> EngineStateDigest

fn replay(_command: &EngineCommand, _ctx: &mut EngineCtx) -> ReplayDisposition

fn mutation_sources() -> &'static [MutationSource]

fn descriptor() -> RestartComponentDescriptor

impl<'a> RestartStateComponent<EngineRecoveryCapture<'a>, EngineCtx, EngineCommand, EngineStateDigest> for MarketCatalogComponent

const NAME: RestartComponentName = RestartComponentName::MarketCatalog

type Snapshot = EngineStateSnapshot

fn capture(ctx: &EngineRecoveryCapture<'a>) -> Self::Snapshot

fn restore(ctx: &mut EngineCtx, snapshot: &Self::Snapshot)

fn digest(ctx: &EngineRecoveryCapture<'a>) -> EngineStateDigest

fn replay(_command: &EngineCommand, _ctx: &mut EngineCtx) -> ReplayDisposition

fn mutation_sources() -> &'static [MutationSource]

fn descriptor() -> RestartComponentDescriptor

impl<'a> RestartStateComponent<EngineRecoveryCapture<'a>, EngineCtx, EngineCommand, EngineStateDigest> for MmpLiquidationComponent

const NAME: RestartComponentName = RestartComponentName::MmpLiquidation

type Snapshot = EngineStateSnapshot

fn capture(ctx: &EngineRecoveryCapture<'a>) -> Self::Snapshot

fn restore(ctx: &mut EngineCtx, snapshot: &Self::Snapshot)

fn digest(ctx: &EngineRecoveryCapture<'a>) -> EngineStateDigest

fn replay(_command: &EngineCommand, _ctx: &mut EngineCtx) -> ReplayDisposition

fn mutation_sources() -> &'static [MutationSource]

fn descriptor() -> RestartComponentDescriptor

impl<'a> RestartStateComponent<EngineRecoveryCapture<'a>, EngineCtx, EngineCommand, EngineStateDigest> for OrderbookStateComponent

const NAME: RestartComponentName = RestartComponentName::OrderbookState

type Snapshot = EngineStateSnapshot

fn capture(ctx: &EngineRecoveryCapture<'a>) -> Self::Snapshot

fn restore(ctx: &mut EngineCtx, snapshot: &Self::Snapshot)

fn digest(ctx: &EngineRecoveryCapture<'a>) -> EngineStateDigest

fn replay(_command: &EngineCommand, _ctx: &mut EngineCtx) -> ReplayDisposition

fn mutation_sources() -> &'static [MutationSource]

fn descriptor() -> RestartComponentDescriptor

impl<'a> RestartStateComponent<EngineRecoveryCapture<'a>, EngineCtx, EngineCommand, EngineStateDigest> for PersistentEngineStateComponent

const NAME: RestartComponentName = RestartComponentName::PersistentEngineStateEnvelope

type Snapshot = EngineStateSnapshot

fn capture(ctx: &EngineRecoveryCapture<'a>) -> Self::Snapshot

fn restore(ctx: &mut EngineCtx, snapshot: &Self::Snapshot)

fn digest(ctx: &EngineRecoveryCapture<'a>) -> EngineStateDigest

fn replay(_command: &EngineCommand, _ctx: &mut EngineCtx) -> ReplayDisposition

fn mutation_sources() -> &'static [MutationSource]

fn descriptor() -> RestartComponentDescriptor

impl<'a> RestartStateComponent<EngineRecoveryCapture<'a>, EngineCtx, EngineCommand, EngineStateDigest> for PmSettlementStateComponent

const NAME: RestartComponentName = RestartComponentName::PmSettlementState

type Snapshot = EngineStateSnapshot

fn capture(ctx: &EngineRecoveryCapture<'a>) -> Self::Snapshot

fn restore(ctx: &mut EngineCtx, snapshot: &Self::Snapshot)

fn digest(ctx: &EngineRecoveryCapture<'a>) -> EngineStateDigest

fn replay(_command: &EngineCommand, _ctx: &mut EngineCtx) -> ReplayDisposition

fn mutation_sources() -> &'static [MutationSource]

fn descriptor() -> RestartComponentDescriptor

impl<'a> RestartStateComponent<EngineRecoveryCapture<'a>, EngineCtx, EngineCommand, EngineStateDigest> for PriceIvInputsComponent

const NAME: RestartComponentName = RestartComponentName::PriceIvInputs

type Snapshot = EngineStateSnapshot

fn capture(ctx: &EngineRecoveryCapture<'a>) -> Self::Snapshot

fn restore(ctx: &mut EngineCtx, snapshot: &Self::Snapshot)

fn digest(ctx: &EngineRecoveryCapture<'a>) -> EngineStateDigest

fn replay(_command: &EngineCommand, _ctx: &mut EngineCtx) -> ReplayDisposition

fn mutation_sources() -> &'static [MutationSource]

fn descriptor() -> RestartComponentDescriptor

impl<'a> RestartStateComponent<EngineRecoveryCapture<'a>, EngineCtx, EngineCommand, EngineStateDigest> for TierRiskLimitsComponent

const NAME: RestartComponentName = RestartComponentName::TierRiskLimits

type Snapshot = EngineStateSnapshot

fn capture(ctx: &EngineRecoveryCapture<'a>) -> Self::Snapshot

fn restore(ctx: &mut EngineCtx, snapshot: &Self::Snapshot)

fn digest(ctx: &EngineRecoveryCapture<'a>) -> EngineStateDigest

fn replay(_command: &EngineCommand, _ctx: &mut EngineCtx) -> ReplayDisposition

fn mutation_sources() -> &'static [MutationSource]

fn descriptor() -> RestartComponentDescriptor