Struct PriceLevels 

pub struct PriceLevels { /* private fields */ }

Entry point for Titan’s pAMM price levels, structured like crate::PropAmmRouter: a single client wrapping a default PriceLevelsSource you can override.

• PriceLevels::get_price_levels reads the latest snapshot from the configured source (one-shot HTTP by default; pass a PriceLevelsWsSource to stream).
• PriceLevels::get_quote / PriceLevels::get_quote_venue resolve a single size against Titan’s latest snapshot over HTTP JSON-RPC. They are HTTP-only — the stream pushes snapshots, not quotes — so they always go through an RPC source.

Implementations

impl PriceLevels

pub fn new() -> Self

Client with the default one-shot HTTP snapshot source.

Examples found in repository

examples/price_levels.rs (line 25)

async fn main() -> Result<(), Box<dyn std::error::Error>> {
    // PriceLevels defaults to a one-shot HTTP snapshot source. Set
    // PRICE_LEVELS_URL to point snapshots and quotes at a specific endpoint.
    let prices = match std::env::var("PRICE_LEVELS_URL") {
        Ok(url) => PriceLevels::with_source(Arc::new(PriceLevelsRpcSource::new(url))),
        Err(_) => PriceLevels::new(),
    };

    // 1. Full snapshot: every pAMM's order book.
    let snapshot = prices.get_price_levels().await?;
    println!(
        "snapshot @ block {} — {} pAMM(s)",
        snapshot
            .block_number
            .map_or_else(|| "?".to_string(), |b| b.to_string()),
        snapshot.pamms.len()
    );

    // Pick the first pAMM/pair that carries an order book to display.
    let Some((pamm, pair)) = snapshot.pamms.iter().find_map(|entry| {
        entry
            .pairs
            .iter()
            .find(|pair| !pair.order_book.is_empty())
            .map(|pair| (entry.pamm, pair))
    }) else {
        return Err("snapshot carried no order books".into());
    };

    println!(
        "\n{} order book: {} -> {}",
        venue_name(pamm),
        token_symbol(pair.token_in),
        token_symbol(pair.token_out),
    );
    for level in &pair.order_book {
        println!(
            "  {} -> {}  [{:?}]",
            fmt(level.amount_in, pair.token_in),
            fmt(level.amount_out, pair.token_out),
            level.variant,
        );
    }

    // 2. Quote helpers, for that pair and a mid-ladder size. `get_quote`
    // returns the best across all pAMMs; `get_quote_venue` pins to one.
    let size = pair.order_book[pair.order_book.len() / 2].amount_in;

    let best = prices
        .get_quote(pair.token_in, pair.token_out, size)
        .await?;
    println!(
        "\nbest quote:  {} -> {} via {}",
        fmt(best.amount_in, best.token_in),
        fmt(best.amount_out, best.token_out),
        venue_name(best.pamm),
    );

    let pinned = prices
        .get_quote_venue(pamm, pair.token_in, pair.token_out, size)
        .await?;
    println!(
        "{} quote: {} -> {}",
        venue_name(pamm),
        fmt(pinned.amount_in, pinned.token_in),
        fmt(pinned.amount_out, pinned.token_out),
    );

    Ok(())
}

pub fn with_source(source: Arc<dyn PriceLevelsSource>) -> Self

Client with an explicit snapshot source. When source already speaks HTTP (a PriceLevelsRpcSource), the quote helpers reuse it so a custom endpoint covers both; otherwise quotes go to the default HTTP endpoint.

Examples found in repository

examples/price_levels.rs (line 24)

async fn main() -> Result<(), Box<dyn std::error::Error>> {
    // PriceLevels defaults to a one-shot HTTP snapshot source. Set
    // PRICE_LEVELS_URL to point snapshots and quotes at a specific endpoint.
    let prices = match std::env::var("PRICE_LEVELS_URL") {
        Ok(url) => PriceLevels::with_source(Arc::new(PriceLevelsRpcSource::new(url))),
        Err(_) => PriceLevels::new(),
    };

    // 1. Full snapshot: every pAMM's order book.
    let snapshot = prices.get_price_levels().await?;
    println!(
        "snapshot @ block {} — {} pAMM(s)",
        snapshot
            .block_number
            .map_or_else(|| "?".to_string(), |b| b.to_string()),
        snapshot.pamms.len()
    );

    // Pick the first pAMM/pair that carries an order book to display.
    let Some((pamm, pair)) = snapshot.pamms.iter().find_map(|entry| {
        entry
            .pairs
            .iter()
            .find(|pair| !pair.order_book.is_empty())
            .map(|pair| (entry.pamm, pair))
    }) else {
        return Err("snapshot carried no order books".into());
    };

    println!(
        "\n{} order book: {} -> {}",
        venue_name(pamm),
        token_symbol(pair.token_in),
        token_symbol(pair.token_out),
    );
    for level in &pair.order_book {
        println!(
            "  {} -> {}  [{:?}]",
            fmt(level.amount_in, pair.token_in),
            fmt(level.amount_out, pair.token_out),
            level.variant,
        );
    }

    // 2. Quote helpers, for that pair and a mid-ladder size. `get_quote`
    // returns the best across all pAMMs; `get_quote_venue` pins to one.
    let size = pair.order_book[pair.order_book.len() / 2].amount_in;

    let best = prices
        .get_quote(pair.token_in, pair.token_out, size)
        .await?;
    println!(
        "\nbest quote:  {} -> {} via {}",
        fmt(best.amount_in, best.token_in),
        fmt(best.amount_out, best.token_out),
        venue_name(best.pamm),
    );

    let pinned = prices
        .get_quote_venue(pamm, pair.token_in, pair.token_out, size)
        .await?;
    println!(
        "{} quote: {} -> {}",
        venue_name(pamm),
        fmt(pinned.amount_in, pinned.token_in),
        fmt(pinned.amount_out, pinned.token_out),
    );

    Ok(())
}

pub fn with_source_and_rpc_url( source: Arc<dyn PriceLevelsSource>, rpc_url: impl Into<String>, ) -> Self

Client with an explicit snapshot source and a specific RPC URL for the quote helpers. Use this when pairing a PriceLevelsWsSource with a private or regional deployment so quotes go to the same host as the stream. When source is a PriceLevelsRpcSource, rpc_url is ignored and the source’s own URL is reused.

pub fn source(&self) -> &Arc<dyn PriceLevelsSource>

The snapshot source Self::get_price_levels pulls from.

pub async fn get_price_levels(&self) -> Result<Arc<PriceLevelsSnapshot>>

Latest price-level snapshot from the configured source.

Examples found in repository

examples/price_levels.rs (line 29)

async fn main() -> Result<(), Box<dyn std::error::Error>> {
    // PriceLevels defaults to a one-shot HTTP snapshot source. Set
    // PRICE_LEVELS_URL to point snapshots and quotes at a specific endpoint.
    let prices = match std::env::var("PRICE_LEVELS_URL") {
        Ok(url) => PriceLevels::with_source(Arc::new(PriceLevelsRpcSource::new(url))),
        Err(_) => PriceLevels::new(),
    };

    // 1. Full snapshot: every pAMM's order book.
    let snapshot = prices.get_price_levels().await?;
    println!(
        "snapshot @ block {} — {} pAMM(s)",
        snapshot
            .block_number
            .map_or_else(|| "?".to_string(), |b| b.to_string()),
        snapshot.pamms.len()
    );

    // Pick the first pAMM/pair that carries an order book to display.
    let Some((pamm, pair)) = snapshot.pamms.iter().find_map(|entry| {
        entry
            .pairs
            .iter()
            .find(|pair| !pair.order_book.is_empty())
            .map(|pair| (entry.pamm, pair))
    }) else {
        return Err("snapshot carried no order books".into());
    };

    println!(
        "\n{} order book: {} -> {}",
        venue_name(pamm),
        token_symbol(pair.token_in),
        token_symbol(pair.token_out),
    );
    for level in &pair.order_book {
        println!(
            "  {} -> {}  [{:?}]",
            fmt(level.amount_in, pair.token_in),
            fmt(level.amount_out, pair.token_out),
            level.variant,
        );
    }

    // 2. Quote helpers, for that pair and a mid-ladder size. `get_quote`
    // returns the best across all pAMMs; `get_quote_venue` pins to one.
    let size = pair.order_book[pair.order_book.len() / 2].amount_in;

    let best = prices
        .get_quote(pair.token_in, pair.token_out, size)
        .await?;
    println!(
        "\nbest quote:  {} -> {} via {}",
        fmt(best.amount_in, best.token_in),
        fmt(best.amount_out, best.token_out),
        venue_name(best.pamm),
    );

    let pinned = prices
        .get_quote_venue(pamm, pair.token_in, pair.token_out, size)
        .await?;
    println!(
        "{} quote: {} -> {}",
        venue_name(pamm),
        fmt(pinned.amount_in, pinned.token_in),
        fmt(pinned.amount_out, pinned.token_out),
    );

    Ok(())
}

pub async fn get_quote( &self, token_in: Address, token_out: Address, amount_in: U256, ) -> Result<TitanQuote>

Best quote across all pAMMs for a size (titan_getPammQuote).

Examples found in repository

examples/price_levels.rs (line 69)

async fn main() -> Result<(), Box<dyn std::error::Error>> {
    // PriceLevels defaults to a one-shot HTTP snapshot source. Set
    // PRICE_LEVELS_URL to point snapshots and quotes at a specific endpoint.
    let prices = match std::env::var("PRICE_LEVELS_URL") {
        Ok(url) => PriceLevels::with_source(Arc::new(PriceLevelsRpcSource::new(url))),
        Err(_) => PriceLevels::new(),
    };

    // 1. Full snapshot: every pAMM's order book.
    let snapshot = prices.get_price_levels().await?;
    println!(
        "snapshot @ block {} — {} pAMM(s)",
        snapshot
            .block_number
            .map_or_else(|| "?".to_string(), |b| b.to_string()),
        snapshot.pamms.len()
    );

    // Pick the first pAMM/pair that carries an order book to display.
    let Some((pamm, pair)) = snapshot.pamms.iter().find_map(|entry| {
        entry
            .pairs
            .iter()
            .find(|pair| !pair.order_book.is_empty())
            .map(|pair| (entry.pamm, pair))
    }) else {
        return Err("snapshot carried no order books".into());
    };

    println!(
        "\n{} order book: {} -> {}",
        venue_name(pamm),
        token_symbol(pair.token_in),
        token_symbol(pair.token_out),
    );
    for level in &pair.order_book {
        println!(
            "  {} -> {}  [{:?}]",
            fmt(level.amount_in, pair.token_in),
            fmt(level.amount_out, pair.token_out),
            level.variant,
        );
    }

    // 2. Quote helpers, for that pair and a mid-ladder size. `get_quote`
    // returns the best across all pAMMs; `get_quote_venue` pins to one.
    let size = pair.order_book[pair.order_book.len() / 2].amount_in;

    let best = prices
        .get_quote(pair.token_in, pair.token_out, size)
        .await?;
    println!(
        "\nbest quote:  {} -> {} via {}",
        fmt(best.amount_in, best.token_in),
        fmt(best.amount_out, best.token_out),
        venue_name(best.pamm),
    );

    let pinned = prices
        .get_quote_venue(pamm, pair.token_in, pair.token_out, size)
        .await?;
    println!(
        "{} quote: {} -> {}",
        venue_name(pamm),
        fmt(pinned.amount_in, pinned.token_in),
        fmt(pinned.amount_out, pinned.token_out),
    );

    Ok(())
}

pub async fn get_quote_venue( &self, venue: Address, token_in: Address, token_out: Address, amount_in: U256, ) -> Result<TitanQuote>

Quote from a specific venue for a size (titan_getPammQuoteVenue).

Examples found in repository

examples/price_levels.rs (line 79)

async fn main() -> Result<(), Box<dyn std::error::Error>> {
    // PriceLevels defaults to a one-shot HTTP snapshot source. Set
    // PRICE_LEVELS_URL to point snapshots and quotes at a specific endpoint.
    let prices = match std::env::var("PRICE_LEVELS_URL") {
        Ok(url) => PriceLevels::with_source(Arc::new(PriceLevelsRpcSource::new(url))),
        Err(_) => PriceLevels::new(),
    };

    // 1. Full snapshot: every pAMM's order book.
    let snapshot = prices.get_price_levels().await?;
    println!(
        "snapshot @ block {} — {} pAMM(s)",
        snapshot
            .block_number
            .map_or_else(|| "?".to_string(), |b| b.to_string()),
        snapshot.pamms.len()
    );

    // Pick the first pAMM/pair that carries an order book to display.
    let Some((pamm, pair)) = snapshot.pamms.iter().find_map(|entry| {
        entry
            .pairs
            .iter()
            .find(|pair| !pair.order_book.is_empty())
            .map(|pair| (entry.pamm, pair))
    }) else {
        return Err("snapshot carried no order books".into());
    };

    println!(
        "\n{} order book: {} -> {}",
        venue_name(pamm),
        token_symbol(pair.token_in),
        token_symbol(pair.token_out),
    );
    for level in &pair.order_book {
        println!(
            "  {} -> {}  [{:?}]",
            fmt(level.amount_in, pair.token_in),
            fmt(level.amount_out, pair.token_out),
            level.variant,
        );
    }

    // 2. Quote helpers, for that pair and a mid-ladder size. `get_quote`
    // returns the best across all pAMMs; `get_quote_venue` pins to one.
    let size = pair.order_book[pair.order_book.len() / 2].amount_in;

    let best = prices
        .get_quote(pair.token_in, pair.token_out, size)
        .await?;
    println!(
        "\nbest quote:  {} -> {} via {}",
        fmt(best.amount_in, best.token_in),
        fmt(best.amount_out, best.token_out),
        venue_name(best.pamm),
    );

    let pinned = prices
        .get_quote_venue(pamm, pair.token_in, pair.token_out, size)
        .await?;
    println!(
        "{} quote: {} -> {}",
        venue_name(pamm),
        fmt(pinned.amount_in, pinned.token_in),
        fmt(pinned.amount_out, pinned.token_out),
    );

    Ok(())
}

pub fn close(&self)

Tear down the snapshot source (closes the stream socket, if any). The HTTP quote path holds no connection, so there is nothing else to release.

Trait Implementations

impl Default for PriceLevels

fn default() -> Self

Returns the “default value” for a type.