Struct CoinbaseInstrumentProvider 

pub struct CoinbaseInstrumentProvider { /* private fields */ }

Loads and caches Coinbase instruments.

Wraps a CoinbaseHttpClient and provides methods for loading instruments from the REST API or from pre-fetched JSON responses. Parsed instruments are cached in the HTTP client’s shared AtomicMap.

Implementations

impl CoinbaseInstrumentProvider

pub fn new(client: CoinbaseHttpClient) -> Self

Creates a new CoinbaseInstrumentProvider.

pub fn instruments(&self) -> &Arc<AtomicMap<InstrumentId, InstrumentAny>>

Returns a reference to the instrument cache.

pub fn count(&self) -> usize

Returns the number of cached instruments.

pub fn get(&self, instrument_id: &InstrumentId) -> Option<InstrumentAny>

Returns a cached instrument by ID, if present.

pub async fn load_all(&self) -> Result<Vec<InstrumentAny>>

Loads all instruments from the Coinbase REST API and caches them.

Errors

Returns an error if the HTTP request fails or the response cannot be parsed.

pub async fn load_all_filtered( &self, product_type: CoinbaseProductType, ) -> Result<Vec<InstrumentAny>>

Loads all instruments of a specific product type from the REST API.

Errors

Returns an error if the HTTP request fails or the response cannot be parsed.

pub async fn load(&self, product_id: &str) -> Result<InstrumentAny>

Loads a single instrument by product ID from the REST API.

Errors

Returns an error if the HTTP request fails or the response cannot be parsed.

pub fn load_from_products_response( &self, json: &Value, ) -> Result<Vec<InstrumentAny>>

Parses a products list response and caches the instruments.

Expects the JSON shape returned by GET /products: {"products": [...]}.

Errors

Returns an error if the JSON cannot be deserialized or any product fails to parse.

pub fn load_from_products_response_filtered( &self, json: &Value, product_type: CoinbaseProductType, ) -> Result<Vec<InstrumentAny>>

Parses a products list response, filtering by product type, and caches the instruments.

Errors

Returns an error if the JSON cannot be deserialized or any product fails to parse.

pub fn load_from_product_response(&self, json: &Value) -> Result<InstrumentAny>

Parses a single product response and caches the instrument.

Expects the JSON shape returned by GET /products/{product_id}.

Errors

Returns an error if the JSON cannot be deserialized or the product fails to parse.

Trait Implementations

impl Clone for CoinbaseInstrumentProvider

fn clone(&self) -> CoinbaseInstrumentProvider

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for CoinbaseInstrumentProvider

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

Formats the value using the given formatter.