Struct PolymarketInstrumentProvider 

pub struct PolymarketInstrumentProvider { /* private fields */ }

Provides Polymarket instruments via the Gamma API.

Wraps PolymarketGammaHttpClient with an [InstrumentStore] and a token_id index for resolving WebSocket asset IDs to instruments.

Optional InstrumentFilters control which instruments are loaded during load_all(). Without filters, all active markets are fetched.

Implementations

impl PolymarketInstrumentProvider

pub fn new(http_client: PolymarketGammaHttpClient) -> Self

Creates a new PolymarketInstrumentProvider with an empty store and no filters.

pub fn with_filters( http_client: PolymarketGammaHttpClient, filters: Vec<Arc<dyn InstrumentFilter>>, ) -> Self

Creates a new PolymarketInstrumentProvider with multiple filters.

pub fn with_filter( http_client: PolymarketGammaHttpClient, filter: Arc<dyn InstrumentFilter>, ) -> Self

Creates a new PolymarketInstrumentProvider with a single filter.

pub fn add_filter(&mut self, filter: Arc<dyn InstrumentFilter>)

Adds an instrument filter for subsequent load_all() calls.

pub fn clear_filters(&mut self)

Clears all instrument filters, reverting to bulk load behavior.

pub fn get_by_token_id(&self, token_id: &Ustr) -> Option<&InstrumentAny>

Returns the instrument for the given token ID, if found.

pub fn build_token_map(&self) -> AHashMap<Ustr, InstrumentAny>

Builds a frozen snapshot mapping token IDs to instruments.

Used to provide the WS handler task with a read-only lookup table after instruments have been loaded.

pub async fn load_by_slugs(&mut self, slugs: Vec<String>) -> Result<()>

Loads instruments for the given slugs additively into the store.

Unlike Self::load_all, this does not clear existing instruments or mark the store as initialized, allowing incremental loading of slug-based markets alongside bulk data.

Errors

Returns an error if the HTTP request or parsing fails.

pub fn filters(&self) -> Vec<Arc<dyn InstrumentFilter>>

Returns a clone of the configured instrument filters.

pub fn http_client(&self) -> &PolymarketGammaHttpClient

Returns a reference to the underlying HTTP client.

pub async fn list_tags(&self) -> Result<Vec<GammaTag>>

Fetches available tags from the Gamma API.

pub fn add_instruments(&mut self, instruments: Vec<InstrumentAny>)

Trait Implementations

impl Debug for PolymarketInstrumentProvider

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

Formats the value using the given formatter.

impl InstrumentProvider for PolymarketInstrumentProvider

fn store(&self) -> &InstrumentStore

Returns a reference to the provider’s instrument store.

fn store_mut(&mut self) -> &mut InstrumentStore

Returns a mutable reference to the provider’s instrument store.

fn load_all<'life0, 'life1, 'async_trait>( &'life0 mut self, filters: Option<&'life1 HashMap<String, String>>, ) -> Pin<Box<dyn Future<Output = Result<()>> + 'async_trait>>

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

Loads all available instruments from the venue.

fn load_ids<'life0, 'life1, 'life2, 'async_trait>( &'life0 mut self, instrument_ids: &'life1 [InstrumentId], filters: Option<&'life2 HashMap<String, String>>, ) -> Pin<Box<dyn Future<Output = Result<()>> + 'async_trait>>

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

Loads specific instruments by their IDs.

fn load<'life0, 'life1, 'life2, 'async_trait>( &'life0 mut self, instrument_id: &'life1 InstrumentId, filters: Option<&'life2 HashMap<String, String>>, ) -> Pin<Box<dyn Future<Output = Result<()>> + 'async_trait>>

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

Loads a single instrument by its ID.