pub struct PolymarketDataClientConfig {Show 24 fields
pub instrument_config: Option<PolymarketInstrumentProviderConfig>,
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 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_fetch_max_concurrency: usize,
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 filters: Vec<Arc<dyn InstrumentFilter>>,
pub new_market_filter: Option<Arc<dyn InstrumentFilter>>,
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>§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>§http_timeout_secs: u64HTTP timeout in seconds.
ws_timeout_secs: u64WebSocket timeout in seconds.
ws_max_subscriptions: usize§update_instruments_interval_mins: Option<u64>Instrument reload interval in minutes.
subscribe_new_markets: boolWhether to subscribe to new market discovery events via WebSocket.
new_market_fetch_max_concurrency: usizeMaximum concurrent instrument fetches spawned from new_market events.
This bounds adapter-side fan-out during event bursts and prevents request storms against Gamma.
auto_load_missing_instruments: boolWhether 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: u64The window (milliseconds) over which concurrent auto-load requests are batched.
auto_load_max_retries: u32Maximum 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: f64Initial 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: f64Maximum delay (seconds) between transient auto-load retries.
resolve_poll_enabled: boolWhether automatic resolve polling is enabled.
resolve_poll_interval_secs: u64Fixed interval between resolve poll cycles in seconds.
resolve_poll_grace_secs: u64Grace period after expiration before a market becomes resolve poll eligible.
resolve_poll_max_wait_secs: u64Maximum number of seconds to keep auto-polling after expiration before pausing.
filters: Vec<Arc<dyn InstrumentFilter>>Instrument filters applied to all instruments during loading and discovery.
new_market_filter: Option<Arc<dyn InstrumentFilter>>Optional filter applied to newly discovered markets before instrument emission.
transport_backend: TransportBackendWebSocket transport backend (defaults to Sockudo).
Implementations§
Source§impl PolymarketDataClientConfig
impl PolymarketDataClientConfig
Sourcepub fn builder() -> PolymarketDataClientConfigBuilder
pub fn builder() -> PolymarketDataClientConfigBuilder
Create an instance of PolymarketDataClientConfig using the builder syntax
Trait Implementations§
Source§impl ClientConfig for PolymarketDataClientConfig
impl ClientConfig for PolymarketDataClientConfig
Source§impl Clone for PolymarketDataClientConfig
impl Clone for PolymarketDataClientConfig
Source§fn clone(&self) -> PolymarketDataClientConfig
fn clone(&self) -> PolymarketDataClientConfig
1.0.0 (const: unstable) · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
source. Read moreSource§impl Debug for PolymarketDataClientConfig
impl Debug for PolymarketDataClientConfig
Source§impl Default for PolymarketDataClientConfig
impl Default for PolymarketDataClientConfig
impl DerefToPyAny for PolymarketDataClientConfig
Source§impl<'de> Deserialize<'de> for PolymarketDataClientConfigwhere
PolymarketDataClientConfig: Default,
impl<'de> Deserialize<'de> for PolymarketDataClientConfigwhere
PolymarketDataClientConfig: Default,
Source§fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>where
__D: Deserializer<'de>,
fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>where
__D: Deserializer<'de>,
Source§impl<'a, 'py> FromPyObject<'a, 'py> for PolymarketDataClientConfigwhere
Self: Clone,
impl<'a, 'py> FromPyObject<'a, 'py> for PolymarketDataClientConfigwhere
Self: Clone,
Source§impl<'py> IntoPyObject<'py> for PolymarketDataClientConfig
impl<'py> IntoPyObject<'py> for PolymarketDataClientConfig
Source§type Target = PolymarketDataClientConfig
type Target = PolymarketDataClientConfig
Source§type Output = Bound<'py, <PolymarketDataClientConfig as IntoPyObject<'py>>::Target>
type Output = Bound<'py, <PolymarketDataClientConfig as IntoPyObject<'py>>::Target>
Source§fn into_pyobject(
self,
py: Python<'py>,
) -> Result<<Self as IntoPyObject<'_>>::Output, <Self as IntoPyObject<'_>>::Error>
fn into_pyobject( self, py: Python<'py>, ) -> Result<<Self as IntoPyObject<'_>>::Output, <Self as IntoPyObject<'_>>::Error>
Source§impl PyClass for PolymarketDataClientConfig
impl PyClass for PolymarketDataClientConfig
Source§impl PyClassImpl for PolymarketDataClientConfig
impl PyClassImpl for PolymarketDataClientConfig
Source§const IS_BASETYPE: bool = false
const IS_BASETYPE: bool = false
Source§const IS_SUBCLASS: bool = false
const IS_SUBCLASS: bool = false
Source§const IS_MAPPING: bool = false
const IS_MAPPING: bool = false
Source§const IS_SEQUENCE: bool = false
const IS_SEQUENCE: bool = false
Source§const IS_IMMUTABLE_TYPE: bool = false
const IS_IMMUTABLE_TYPE: bool = false
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.
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.
Source§const DOC: &'static CStr
const DOC: &'static CStr
text_signature if a constructor is defined. Read moreSource§type Layout = <<PolymarketDataClientConfig as PyClassImpl>::BaseNativeType as PyClassBaseType>::Layout<PolymarketDataClientConfig>
type Layout = <<PolymarketDataClientConfig as PyClassImpl>::BaseNativeType as PyClassBaseType>::Layout<PolymarketDataClientConfig>
Source§type ThreadChecker = NoopThreadChecker
type ThreadChecker = NoopThreadChecker
type Inventory = Pyo3MethodsInventoryForPolymarketDataClientConfig
Source§type PyClassMutability = <<PyAny as PyClassBaseType>::PyClassMutability as PyClassMutability>::MutableChild
type PyClassMutability = <<PyAny as PyClassBaseType>::PyClassMutability as PyClassMutability>::MutableChild
Source§type BaseNativeType = PyAny
type BaseNativeType = PyAny
PyAny by default, and when you declare
#[pyclass(extends=PyDict)], it’s PyDict.fn items_iter() -> PyClassItemsIter
fn lazy_type_object() -> &'static LazyTypeObject<Self>
§fn dict_offset() -> Option<PyObjectOffset>
fn dict_offset() -> Option<PyObjectOffset>
§fn weaklist_offset() -> Option<PyObjectOffset>
fn weaklist_offset() -> Option<PyObjectOffset>
Source§impl PyClassNewTextSignature for PolymarketDataClientConfig
impl PyClassNewTextSignature for PolymarketDataClientConfig
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)"
Source§impl PyStubType for PolymarketDataClientConfig
impl PyStubType for PolymarketDataClientConfig
Source§fn type_output() -> TypeInfo
fn type_output() -> TypeInfo
§fn type_input() -> TypeInfo
fn type_input() -> TypeInfo
Source§impl PyTypeInfo for PolymarketDataClientConfig
impl PyTypeInfo for PolymarketDataClientConfig
Source§const NAME: &str = <Self as ::pyo3::PyClass>::NAME
const NAME: &str = <Self as ::pyo3::PyClass>::NAME
prefer using ::type_object(py).name() to get the correct runtime value
Source§const MODULE: Option<&str> = <Self as ::pyo3::impl_::pyclass::PyClassImpl>::MODULE
const MODULE: Option<&str> = <Self as ::pyo3::impl_::pyclass::PyClassImpl>::MODULE
prefer using ::type_object(py).module() to get the correct runtime value
Source§fn type_object_raw(py: Python<'_>) -> *mut PyTypeObject
fn type_object_raw(py: Python<'_>) -> *mut PyTypeObject
§fn type_object(py: Python<'_>) -> Bound<'_, PyType>
fn type_object(py: Python<'_>) -> Bound<'_, PyType>
§fn is_type_of(object: &Bound<'_, PyAny>) -> bool
fn is_type_of(object: &Bound<'_, PyAny>) -> bool
object is an instance of this type or a subclass of this type.§fn is_exact_type_of(object: &Bound<'_, PyAny>) -> bool
fn is_exact_type_of(object: &Bound<'_, PyAny>) -> bool
object is an instance of this type.Auto Trait Implementations§
impl !RefUnwindSafe for PolymarketDataClientConfig
impl !UnwindSafe for PolymarketDataClientConfig
impl Freeze for PolymarketDataClientConfig
impl Send for PolymarketDataClientConfig
impl Sync for PolymarketDataClientConfig
impl Unpin for PolymarketDataClientConfig
impl UnsafeUnpin for PolymarketDataClientConfig
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
impl<'de, T> BorrowedRpcObject<'de> for Twhere
T: RpcBorrow<'de> + RpcSend,
impl<ST, DT> CastableFrom<ST, Initialized, Initialized> for DT
impl<ST, DT> CastableFrom<ST, Uninit, Uninit> for DT
Source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> DeserializeOwned for Twhere
T: for<'de> Deserialize<'de>,
impl<'py, T> FromPyObjectOwned<'py> for Twhere
T: for<'a> FromPyObject<'a, 'py>,
§impl<T> Instrument for T
impl<T> Instrument for T
§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self>
fn into_either(self, into_left: bool) -> Either<Self, Self>
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 moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
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 Twhere
T: IntoPyObject<'py>,
impl<'py, T> IntoPyObjectExt<'py> for Twhere
T: IntoPyObject<'py>,
§fn into_bound_py_any(self, py: Python<'py>) -> Result<Bound<'py, PyAny>, PyErr>
fn into_bound_py_any(self, py: Python<'py>) -> Result<Bound<'py, PyAny>, PyErr>
self into an owned Python object, dropping type information.§fn into_py_any(self, py: Python<'py>) -> Result<Py<PyAny>, PyErr>
fn into_py_any(self, py: Python<'py>) -> Result<Py<PyAny>, PyErr>
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>
fn into_pyobject_or_pyerr(self, py: Python<'py>) -> Result<Self::Output, PyErr>
self into a Python object. Read more§impl<'py, T> IntoPyObjectNautilusExt<'py> for Twhere
T: IntoPyObjectExt<'py>,
impl<'py, T> IntoPyObjectNautilusExt<'py> for Twhere
T: IntoPyObjectExt<'py>,
§fn into_py_any_unwrap(self, py: Python<'py>) -> Py<PyAny>
fn into_py_any_unwrap(self, py: Python<'py>) -> Py<PyAny>
§impl<T> PolicyExt for Twhere
T: ?Sized,
impl<T> PolicyExt for Twhere
T: ?Sized,
§impl<T> PyErrArguments for T
impl<T> PyErrArguments for T
§impl<T> PyTypeCheck for Twhere
T: PyTypeInfo,
impl<T> PyTypeCheck for Twhere
T: PyTypeInfo,
§fn type_check(object: &Bound<'_, PyAny>) -> bool
fn type_check(object: &Bound<'_, PyAny>) -> bool
§fn classinfo_object(py: Python<'_>) -> Bound<'_, PyAny>
fn classinfo_object(py: Python<'_>) -> Bound<'_, PyAny>
isinstance and issubclass function. Read more