pub struct BlockchainDataClientConfig {
pub chain: SharedChain,
pub dex_ids: Vec<DexType>,
pub use_hypersync_for_live_data: bool,
pub http_rpc_url: String,
pub rpc_requests_per_second: Option<u32>,
pub multicall_calls_per_rpc_request: u32,
pub wss_rpc_url: Option<String>,
pub http_proxy_url: Option<String>,
pub ws_proxy_url: Option<String>,
pub from_block: Option<u64>,
pub pool_filters: DexPoolFilters,
pub postgres_cache_database_config: Option<PostgresConnectOptions>,
}Expand description
Configuration for blockchain data clients.
Fields§
§chain: SharedChainThe blockchain chain configuration.
dex_ids: Vec<DexType>List of decentralized exchange IDs to register and sync during connection.
use_hypersync_for_live_data: boolDetermines if the client should use Hypersync for live data streaming.
http_rpc_url: StringThe HTTP URL for the blockchain RPC endpoint.
rpc_requests_per_second: Option<u32>The maximum number of RPC requests allowed per second.
multicall_calls_per_rpc_request: u32The maximum number of Multicall calls per one RPC request.
wss_rpc_url: Option<String>The WebSocket secure URL for the blockchain RPC endpoint.
http_proxy_url: Option<String>Optional HTTP proxy URL for RPC requests.
ws_proxy_url: Option<String>Optional WebSocket proxy URL for RPC connections.
Note: WebSocket proxy support is not yet implemented. This field is reserved
for future functionality. Use http_proxy_url for REST API proxy support.
from_block: Option<u64>The block from which to sync historical data.
pool_filters: DexPoolFiltersFiltering criteria that define which DEX pools to include in the data universe.
postgres_cache_database_config: Option<PostgresConnectOptions>Optional configuration for data client’s Postgres cache database
Implementations§
Source§impl BlockchainDataClientConfig
impl BlockchainDataClientConfig
Sourcepub fn new(
chain: SharedChain,
dex_ids: Vec<DexType>,
http_rpc_url: String,
rpc_requests_per_second: Option<u32>,
multicall_calls_per_rpc_request: Option<u32>,
wss_rpc_url: Option<String>,
use_hypersync_for_live_data: bool,
from_block: Option<u64>,
pools_filters: Option<DexPoolFilters>,
postgres_cache_database_config: Option<PostgresConnectOptions>,
) -> Self
pub fn new( chain: SharedChain, dex_ids: Vec<DexType>, http_rpc_url: String, rpc_requests_per_second: Option<u32>, multicall_calls_per_rpc_request: Option<u32>, wss_rpc_url: Option<String>, use_hypersync_for_live_data: bool, from_block: Option<u64>, pools_filters: Option<DexPoolFilters>, postgres_cache_database_config: Option<PostgresConnectOptions>, ) -> Self
Creates a new BlockchainDataClientConfig instance.
Trait Implementations§
Source§impl Clone for BlockchainDataClientConfig
impl Clone for BlockchainDataClientConfig
Source§fn clone(&self) -> BlockchainDataClientConfig
fn clone(&self) -> BlockchainDataClientConfig
1.0.0 · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
source. Read moreSource§impl Debug for BlockchainDataClientConfig
impl Debug for BlockchainDataClientConfig
Source§impl<'py> IntoPyObject<'py> for BlockchainDataClientConfig
impl<'py> IntoPyObject<'py> for BlockchainDataClientConfig
Source§type Target = BlockchainDataClientConfig
type Target = BlockchainDataClientConfig
Source§type Output = Bound<'py, <BlockchainDataClientConfig as IntoPyObject<'py>>::Target>
type Output = Bound<'py, <BlockchainDataClientConfig 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 BlockchainDataClientConfig
impl PyClass for BlockchainDataClientConfig
Source§impl PyClassImpl for BlockchainDataClientConfig
impl PyClassImpl for BlockchainDataClientConfig
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 blockchain data clients.
const RAW_DOC: &'static CStr = /// Configuration for blockchain data clients.
Source§const DOC: &'static CStr
const DOC: &'static CStr
text_signature if a constructor is defined. Read moreSource§type ThreadChecker = SendablePyClass<BlockchainDataClientConfig>
type ThreadChecker = SendablePyClass<BlockchainDataClientConfig>
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<isize>
fn weaklist_offset() -> Option<isize>
Source§impl PyClassNewTextSignature for BlockchainDataClientConfig
impl PyClassNewTextSignature for BlockchainDataClientConfig
const TEXT_SIGNATURE: &'static str = "(chain, dex_ids, http_rpc_url, rpc_requests_per_second=None, multicall_calls_per_rpc_request=None, wss_rpc_url=None, use_hypersync_for_live_data=True, from_block=None, pool_filters=None, postgres_cache_database_config=None)"
Source§impl PyMethods<BlockchainDataClientConfig> for PyClassImplCollector<BlockchainDataClientConfig>
impl PyMethods<BlockchainDataClientConfig> for PyClassImplCollector<BlockchainDataClientConfig>
fn py_methods(self) -> &'static PyClassItems
Source§impl PyStubType for BlockchainDataClientConfig
impl PyStubType for BlockchainDataClientConfig
Source§fn type_output() -> TypeInfo
fn type_output() -> TypeInfo
§fn type_input() -> TypeInfo
fn type_input() -> TypeInfo
Source§impl PyTypeInfo for BlockchainDataClientConfig
impl PyTypeInfo for BlockchainDataClientConfig
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.impl DerefToPyAny for BlockchainDataClientConfig
impl ExtractPyClassWithClone for BlockchainDataClientConfig
Auto Trait Implementations§
impl Freeze for BlockchainDataClientConfig
impl RefUnwindSafe for BlockchainDataClientConfig
impl Send for BlockchainDataClientConfig
impl Sync for BlockchainDataClientConfig
impl Unpin for BlockchainDataClientConfig
impl UnwindSafe for BlockchainDataClientConfig
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
Source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
§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 moreSource§impl<'py, T> IntoPyObjectNautilusExt<'py> for Twhere
T: IntoPyObjectExt<'py>,
impl<'py, T> IntoPyObjectNautilusExt<'py> for Twhere
T: IntoPyObjectExt<'py>,
Source§fn into_py_any_unwrap(self, py: Python<'py>) -> Py<PyAny>
fn into_py_any_unwrap(self, py: Python<'py>) -> Py<PyAny>
§impl<T> Pointable for T
impl<T> Pointable for T
§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,
§const NAME: &'static str = T::NAME
const NAME: &'static str = T::NAME
§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