Struct PriceLevelStreamState 

pub struct PriceLevelStreamState {
    pub token0: Bytes,
    pub token1: Bytes,
    pub quotes_0_to_1: Vec<PriceLevelStreamQuote>,
    pub quotes_1_to_0: Vec<PriceLevelStreamQuote>,
    pub gas_cost: BigUint,
    /* private fields */
}

State of a single pAMM pair fed from the price level stream.

Holds the latest complete quote ladders for both trade directions. Quotes are absolute (amount_in → total amount_out), sorted ascending by amount_in; amounts between two quotes are interpolated linearly, mirroring how Titan itself densifies the simulated levels. Amounts outside the quoted range are not served.

Fields

token0: Bytes

token1: Bytes

quotes_0_to_1: Vec<PriceLevelStreamQuote>

quotes_1_to_0: Vec<PriceLevelStreamQuote>

gas_cost: BigUint

Implementations

impl PriceLevelStreamState

pub fn new( token0: Bytes, token1: Bytes, quotes_0_to_1: Vec<PriceLevelStreamQuote>, quotes_1_to_0: Vec<PriceLevelStreamQuote>, gas_cost: BigUint, ) -> Self

Creates the state for the pair (token0, token1).

Both quote ladders are sorted ascending by amount_in and deduplicated on it, so callers may pass them in stream order.

pub fn with_quotable_until(self, until: Instant) -> Self

Sets the monotonic instant from which this state refuses every query.

pub fn quotable_until(&self) -> Option<Instant>

The monotonic instant from which this state refuses every query, or None if it never expires.

Trait Implementations

impl Clone for PriceLevelStreamState

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for PriceLevelStreamState

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for PriceLevelStreamState

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl ProtocolSim for PriceLevelStreamState

fn eq(&self, other: &dyn ProtocolSim) -> bool

Equal when the pair, both ladders and the gas cost match. quotable_until is left out: it is per-process metadata that never survives serialization, and a consumer that skips a state because it equals the one it holds keeps quoting on the older guard.

fn fee(&self) -> f64

Returns the fee of the protocol as ratio

fn spot_price( &self, base: &Token, quote: &Token, ) -> Result<f64, SimulationError>

Returns the protocol’s current spot buy price for base in units of quote.

fn get_amount_out( &self, amount_in: BigUint, token_in: &Token, token_out: &Token, ) -> Result<GetAmountOutResult, SimulationError>

Returns the amount out given an amount in and input/output tokens.

fn get_limits( &self, sell_token: Bytes, buy_token: Bytes, ) -> Result<(BigUint, BigUint), SimulationError>

Computes the maximum amount that can be traded between two tokens.

fn delta_transition( &mut self, _delta: ProtocolStateDelta, _tokens: &HashMap<Bytes, Token>, _balances: &Balances, ) -> Result<(), TransitionError>

Decodes and applies a protocol state delta to the state

fn clone_box(&self) -> Box<dyn ProtocolSim>

Clones the protocol state as a trait object. This allows the state to be cloned when it is being used as a Box<dyn ProtocolSim>.

fn as_any(&self) -> &dyn Any

Allows downcasting of the trait object to its underlying type.

fn as_any_mut(&mut self) -> &mut dyn Any

Allows downcasting of the trait object to its mutable underlying type.

fn query_pool_swap( &self, params: &QueryPoolSwapParams, ) -> Result<PoolSwap, SimulationError>

Calculates the swap volume required to achieve the provided goal when trading against this pool.

fn as_indicatively_priced( &self, ) -> Result<&(dyn IndicativelyPriced + 'static), SimulationError>

Cast as IndicativelyPriced. This is necessary for RFQ protocols

fn apply_block(&mut self, _block: &BlockContext) -> bool

Advances the state to the block a quote is expected to execute in.

fn set_pending_overrides( &mut self, _overrides: Arc<dyn Any + Sync + Send>, ) -> Result<(), SimulationError>

Runs every later quote from this state under a pending block’s state, held in overrides.

impl Serialize for PriceLevelStreamState

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.