Skip to main content

PolymarketDataClientConfig

Struct PolymarketDataClientConfig 

Source
pub struct PolymarketDataClientConfig {
Show 27 fields pub instrument_config: Option<PolymarketInstrumentProviderConfig>, pub filters: Vec<Arc<dyn InstrumentFilter>>, pub base_url_http: Option<String>, pub base_url_ws: Option<String>, pub base_url_rtds: Option<String>, pub base_url_gamma: Option<String>, pub base_url_data_api: Option<String>, pub proxy_url: Option<String>, pub http_timeout_secs: u64, pub ws_timeout_secs: u64, pub ws_max_subscriptions: usize, pub update_instruments_interval_mins: Option<u64>, pub subscribe_new_markets: bool, pub new_market_filter: Option<Arc<dyn InstrumentFilter>>, pub new_market_fetch_max_concurrency: usize, pub drop_quotes_missing_side: bool, pub compute_effective_deltas: bool, pub auto_load_missing_instruments: bool, pub auto_load_debounce_ms: u64, pub auto_load_max_retries: u32, pub auto_load_retry_delay_initial_secs: f64, pub auto_load_retry_delay_max_secs: f64, pub resolve_poll_enabled: bool, pub resolve_poll_interval_secs: u64, pub resolve_poll_grace_secs: u64, pub resolve_poll_max_wait_secs: u64, pub transport_backend: TransportBackend,
}
Expand description

Configuration for the Polymarket data client.

filters and new_market_filter hold Arc<dyn InstrumentFilter> trait objects and are skipped during serialization; they default to empty/None and must be installed programmatically after deserialization.

Fields§

§instrument_config: Option<PolymarketInstrumentProviderConfig>§filters: Vec<Arc<dyn InstrumentFilter>>

Instrument filters applied to all instruments during loading and discovery.

§base_url_http: Option<String>§base_url_ws: Option<String>§base_url_rtds: Option<String>§base_url_gamma: Option<String>§base_url_data_api: Option<String>§proxy_url: Option<String>

Optional HTTP or HTTPS proxy URL for all HTTP and WebSocket transports.

§http_timeout_secs: u64

HTTP timeout in seconds.

§ws_timeout_secs: u64

WebSocket timeout in seconds.

§ws_max_subscriptions: usize§update_instruments_interval_mins: Option<u64>

Instrument reload interval in minutes.

§subscribe_new_markets: bool

Whether to subscribe to new-market discovery, resolution, and best-bid/ask events.

§new_market_filter: Option<Arc<dyn InstrumentFilter>>

Optional filter applied to newly discovered markets before instrument emission.

§new_market_fetch_max_concurrency: usize

Maximum concurrent instrument fetches spawned from new_market events.

This bounds adapter-side fan-out during event bursts and prevents request storms against Gamma.

§drop_quotes_missing_side: bool

Whether to drop quote ticks when bid or ask prices are missing.

§compute_effective_deltas: bool

Whether to maintain local book state and emit only the net changes from book snapshots, at an additional CPU and memory cost.

§auto_load_missing_instruments: bool

Whether subscribe and request commands referencing an unknown instrument should trigger an ad-hoc load via the instrument provider. Concurrent misses within auto_load_debounce_ms are coalesced into a single batched request.

§auto_load_debounce_ms: u64

The window (milliseconds) over which concurrent auto-load requests are batched.

§auto_load_max_retries: u32

Maximum retry attempts on transient auto-load failures (markets in the CLOB hydration window that return empty clob_token_ids from Gamma, or that are absent from the bulk response). Set to 0 to disable retry.

§auto_load_retry_delay_initial_secs: f64

Initial delay (seconds) between transient auto-load retries; backed off exponentially with positive jitter up to auto_load_retry_delay_max_secs.

§auto_load_retry_delay_max_secs: f64

Maximum delay (seconds) between transient auto-load retries.

§resolve_poll_enabled: bool

Whether automatic resolve polling is enabled.

§resolve_poll_interval_secs: u64

Fixed interval between resolve poll cycles in seconds.

§resolve_poll_grace_secs: u64

Grace period after expiration before a market becomes resolve poll eligible.

§resolve_poll_max_wait_secs: u64

Maximum number of seconds to keep auto-polling after expiration before pausing.

§transport_backend: TransportBackend

WebSocket transport backend (defaults to Sockudo).

Implementations§

Source§

impl PolymarketDataClientConfig

Source

pub fn builder() -> PolymarketDataClientConfigBuilder

Create an instance of PolymarketDataClientConfig using the builder syntax

Source§

impl PolymarketDataClientConfig

Source

pub fn new() -> Self

Source

pub fn validated_proxy_url(&self) -> Result<Option<ProxyUrl>, TransportError>

Returns the validated proxy URL, if configured.

§Errors

Returns an error when the URL is malformed, has no host, or does not use HTTP or HTTPS.

Source

pub const fn has_proxy_url(&self) -> bool

Source

pub fn http_url(&self) -> String

Source

pub fn ws_url(&self) -> String

Source

pub fn rtds_url(&self) -> String

Source

pub fn gamma_url(&self) -> String

Source

pub fn data_api_url(&self) -> String

Trait Implementations§

Source§

impl ClientConfig for PolymarketDataClientConfig

Source§

fn as_any(&self) -> &dyn Any

Return the configuration as a trait object.
Source§

impl Clone for PolymarketDataClientConfig

Source§

fn clone(&self) -> PolymarketDataClientConfig

Returns a duplicate of the value. Read more
1.0.0 (const: unstable) · Source§

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

Performs copy-assignment from source. Read more
Source§

impl Debug for PolymarketDataClientConfig

Source§

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

Formats the value using the given formatter. Read more
Source§

impl Default for PolymarketDataClientConfig

Source§

fn default() -> Self

Returns the “default value” for a type. Read more
Source§

impl DerefToPyAny for PolymarketDataClientConfig

Source§

impl<'de> Deserialize<'de> for PolymarketDataClientConfig

Source§

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>
where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer. Read more
Source§

impl<'a, 'py> FromPyObject<'a, 'py> for PolymarketDataClientConfig
where Self: Clone,

Source§

type Error = PyClassGuardError<'a, 'py>

The type returned in the event of a conversion error. Read more
Source§

fn extract( obj: Borrowed<'a, 'py, PyAny>, ) -> Result<Self, <Self as FromPyObject<'a, 'py>>::Error>

Extracts Self from the bound smart pointer obj. Read more
Source§

impl<'py> IntoPyObject<'py> for PolymarketDataClientConfig

Source§

type Target = PolymarketDataClientConfig

The Python output type
Source§

type Output = Bound<'py, <PolymarketDataClientConfig as IntoPyObject<'py>>::Target>

The smart pointer type to use. Read more
Source§

type Error = PyErr

The type returned in the event of a conversion error.
Source§

fn into_pyobject( self, py: Python<'py>, ) -> Result<<Self as IntoPyObject<'_>>::Output, <Self as IntoPyObject<'_>>::Error>

Performs the conversion.
Source§

impl PyClass for PolymarketDataClientConfig

Source§

const NAME: &str = "PolymarketDataClientConfig"

Name of the class. Read more
Source§

type Frozen = False

Whether the pyclass is frozen. Read more
Source§

impl PyClassImpl for PolymarketDataClientConfig

Source§

const MODULE: Option<&str>

Module which the class will be associated with. Read more
Source§

const IS_BASETYPE: bool = false

#[pyclass(subclass)]
Source§

const IS_SUBCLASS: bool = false

#[pyclass(extends=…)]
Source§

const IS_MAPPING: bool = false

#[pyclass(mapping)]
Source§

const IS_SEQUENCE: bool = false

#[pyclass(sequence)]
Source§

const IS_IMMUTABLE_TYPE: bool = false

#[pyclass(immutable_type)]
Source§

const RAW_DOC: &'static CStr = /// Configuration for the Polymarket data client. /// /// `filters` and `new_market_filter` hold `Arc<dyn InstrumentFilter>` trait objects /// and are skipped during serialization; they default to empty/`None` and must be /// installed programmatically after deserialization.

Docstring for the class provided on the struct or enum. Read more
Source§

const DOC: &'static CStr

Fully rendered class doc, including the text_signature if a constructor is defined. Read more
Source§

type Layout = <<PolymarketDataClientConfig as PyClassImpl>::BaseNativeType as PyClassBaseType>::Layout<PolymarketDataClientConfig>

Description of how this class is laid out in memory
Source§

type BaseType = PyAny

Base class
Source§

type ThreadChecker = NoopThreadChecker

This handles following two situations: Read more
Source§

type Inventory = Pyo3MethodsInventoryForPolymarketDataClientConfig

Source§

type PyClassMutability = <<PyAny as PyClassBaseType>::PyClassMutability as PyClassMutability>::MutableChild

Immutable or mutable
Source§

type Dict = PyClassDummySlot

Specify this class has #[pyclass(dict)] or not.
Source§

type WeakRef = PyClassDummySlot

Specify this class has #[pyclass(weakref)] or not.
Source§

type BaseNativeType = PyAny

The closest native ancestor. This is PyAny by default, and when you declare #[pyclass(extends=PyDict)], it’s PyDict.
Source§

fn items_iter() -> PyClassItemsIter

Source§

fn lazy_type_object() -> &'static LazyTypeObject<Self>

§

fn dict_offset() -> Option<PyObjectOffset>

Used to provide the dictoffset slot (equivalent to tp_dictoffset)
§

fn weaklist_offset() -> Option<PyObjectOffset>

Used to provide the weaklistoffset slot (equivalent to tp_weaklistoffset
Source§

impl PyClassNewTextSignature for PolymarketDataClientConfig

Source§

const TEXT_SIGNATURE: &'static str = "(instrument_config=None, base_url_http=None, base_url_ws=None, base_url_gamma=None, base_url_data_api=None, http_timeout_secs=None, ws_timeout_secs=None, ws_max_subscriptions=None, update_instruments_interval_mins=..., subscribe_new_markets=None, auto_load_missing_instruments=None, auto_load_debounce_ms=None, auto_load_max_retries=None, auto_load_retry_delay_initial_secs=None, auto_load_retry_delay_max_secs=None, new_market_fetch_max_concurrency=None, resolve_poll_enabled=None, resolve_poll_interval_secs=None, resolve_poll_grace_secs=None, resolve_poll_max_wait_secs=None, base_url_rtds=None, transport_backend=None, drop_quotes_missing_side=None, proxy_url=None, compute_effective_deltas=None)"

Source§

impl PyStubType for PolymarketDataClientConfig

Source§

fn type_output() -> TypeInfo

The type to be used in the output signature, i.e. return type of the Python function or methods.
§

fn type_input() -> TypeInfo

The type to be used in the input signature, i.e. the arguments of the Python function or methods. Read more
Source§

impl PyTypeInfo for PolymarketDataClientConfig

Source§

const NAME: &str = <Self as ::pyo3::PyClass>::NAME

👎Deprecated since 0.28.0:

prefer using ::type_object(py).name() to get the correct runtime value

Class name.
Source§

const MODULE: Option<&str> = <Self as ::pyo3::impl_::pyclass::PyClassImpl>::MODULE

👎Deprecated since 0.28.0:

prefer using ::type_object(py).module() to get the correct runtime value

Module name, if any.
Source§

fn type_object_raw(py: Python<'_>) -> *mut PyTypeObject

Returns the PyTypeObject instance for this type.
§

fn type_object(py: Python<'_>) -> Bound<'_, PyType>

Returns the safe abstraction over the type object.
§

fn is_type_of(object: &Bound<'_, PyAny>) -> bool

Checks if object is an instance of this type or a subclass of this type.
§

fn is_exact_type_of(object: &Bound<'_, PyAny>) -> bool

Checks if object is an instance of this type.
Source§

impl Serialize for PolymarketDataClientConfig

Source§

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

Serialize this value into the given Serde serializer. Read more

Auto Trait Implementations§

Blanket Implementations§

Source§

impl<T> Any for T
where T: 'static + ?Sized,

Source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
Source§

impl<T> Borrow<T> for T
where T: ?Sized,

Source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
Source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

Source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
§

impl<'de, T> BorrowedRpcObject<'de> for T
where T: RpcBorrow<'de> + RpcSend,

§

impl<ST, DT> CastableFrom<ST, Initialized, Initialized> for DT
where ST: ?Sized, DT: ?Sized,

§

impl<ST, DT> CastableFrom<ST, Uninit, Uninit> for DT
where ST: ?Sized, DT: ?Sized,

Source§

impl<T> CloneToUninit for T
where T: Clone,

Source§

unsafe fn clone_to_uninit(&self, dest: *mut u8)

🔬This is a nightly-only experimental API. (clone_to_uninit)
Performs copy-assignment from self to dest. Read more
Source§

impl<T> DeserializeOwned for T
where T: for<'de> Deserialize<'de>,

Source§

impl<T> From<T> for T

Source§

fn from(t: T) -> T

Returns the argument unchanged.

§

impl<'py, T> FromPyObjectOwned<'py> for T
where T: for<'a> FromPyObject<'a, 'py>,

§

impl<T> Instrument for T

§

fn instrument(self, span: Span) -> Instrumented<Self>

Instruments this type with the provided [Span], returning an Instrumented wrapper. Read more
§

fn in_current_span(self) -> Instrumented<Self>

Instruments this type with the current Span, returning an Instrumented wrapper. Read more
Source§

impl<T, U> Into<U> for T
where U: From<T>,

Source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Source§

impl<T> IntoEither for T

Source§

fn into_either(self, into_left: bool) -> Either<Self, Self>

Converts self into a Left variant of Either<Self, Self> if into_left is true. Converts self into a Right variant of Either<Self, Self> otherwise. Read more
Source§

fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
where F: FnOnce(&Self) -> bool,

Converts self into a Left variant of Either<Self, Self> if into_left(&self) returns true. Converts self into a Right variant of Either<Self, Self> otherwise. Read more
§

impl<'py, T> IntoPyObjectExt<'py> for T
where T: IntoPyObject<'py>,

§

fn into_bound_py_any(self, py: Python<'py>) -> Result<Bound<'py, PyAny>, PyErr>

Converts self into an owned Python object, dropping type information.
§

fn into_py_any(self, py: Python<'py>) -> Result<Py<PyAny>, PyErr>

Converts self into an owned Python object, dropping type information and unbinding it from the 'py lifetime.
§

fn into_pyobject_or_pyerr(self, py: Python<'py>) -> Result<Self::Output, PyErr>

Converts self into a Python object. Read more
§

impl<'py, T> IntoPyObjectNautilusExt<'py> for T
where T: IntoPyObjectExt<'py>,

§

fn into_py_any_unwrap(self, py: Python<'py>) -> Py<PyAny>
where Self: IntoPyObject<'py, Error = !>,

Converts self into a [Py<PyAny>] when the underlying conversion is infallible.
§

impl<T> PolicyExt for T
where T: ?Sized,

§

fn and<P, B, E>(self, other: P) -> And<T, P>
where T: Sized + Policy<B, E>, P: Policy<B, E>,

Create a new Policy that returns [Action::Follow] only if self and other return Action::Follow. Read more
§

fn or<P, B, E>(self, other: P) -> Or<T, P>
where T: Sized + Policy<B, E>, P: Policy<B, E>,

Create a new Policy that returns [Action::Follow] if either self or other returns Action::Follow. Read more
§

impl<T> PyErrArguments for T
where T: for<'py> IntoPyObject<'py> + Send + Sync,

§

fn arguments(self, py: Python<'_>) -> Py<PyAny>

Arguments for exception
§

impl<T> PyTypeCheck for T
where T: PyTypeInfo,

§

fn type_check(object: &Bound<'_, PyAny>) -> bool

Checks if object is an instance of Self, which may include a subtype. Read more
§

fn classinfo_object(py: Python<'_>) -> Bound<'_, PyAny>

Returns the expected type as a possible argument for the isinstance and issubclass function. Read more
§

impl<T> Read<Exclusive, BecauseExclusive> for T
where T: ?Sized,

§

impl<'de, T> RpcBorrow<'de> for T
where T: Deserialize<'de> + Debug + Send + Sync + Unpin,

§

impl<T> RpcObject for T
where T: RpcSend + RpcRecv,

§

impl<T> RpcRecv for T
where T: DeserializeOwned + Debug + Send + Sync + Unpin + 'static,

§

impl<T> RpcSend for T
where T: Serialize + Clone + Debug + Send + Sync + Unpin,

Source§

impl<T> Same for T

Source§

type Output = T

Should always be Self
Source§

impl<T> ToOwned for T
where T: Clone,

Source§

type Owned = T

The resulting type after obtaining ownership.
Source§

fn to_owned(&self) -> T

Creates owned data from borrowed data, usually by cloning. Read more
Source§

fn clone_into(&self, target: &mut T)

Uses borrowed data to replace owned data, usually by cloning. Read more
Source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

Source§

type Error = !

The type returned in the event of a conversion error.
Source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
Source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

Source§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
Source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.
§

impl<T> Ungil for T
where T: Send,

§

impl<V, T> VZip<V> for T
where V: MultiLane<T>,

§

fn vzip(self) -> V

§

impl<T> WithSubscriber for T

§

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,

Attaches the provided Subscriber to this type, returning a [WithDispatch] wrapper. Read more
§

fn with_current_subscriber(self) -> WithDispatch<Self>

Attaches the current default Subscriber to this type, returning a [WithDispatch] wrapper. Read more