pub struct HyperliquidDataClientConfig {Show 15 fields
pub private_key: Option<String>,
pub base_url_ws: Option<String>,
pub base_url_http: Option<String>,
pub proxy_url: Option<String>,
pub environment: HyperliquidEnvironment,
pub http_timeout_secs: u64,
pub ws_timeout_secs: u64,
pub stale_stream_receive_timeout_secs: u64,
pub stream_health_check_interval_secs: u64,
pub stale_stream_warning_cooldown_secs: u64,
pub stale_stream_recovery_enabled: bool,
pub stale_stream_recovery_cooldown_secs: u64,
pub stale_stream_max_targeted_resubscribes: u32,
pub update_instruments_interval_mins: u64,
pub transport_backend: TransportBackend,
}Expand description
Configuration for the Hyperliquid data client.
The stale_stream_* options control the stream health monitor. With recovery
enabled, a stale stream is warned about first, targeted-resubscribed once per
recovery cooldown (preserving its original l2Book options), and escalated to
a full WebSocket reconnect after stale_stream_max_targeted_resubscribes
failed attempts; fresh data resets the ladder. See the Hyperliquid integration
guide (“Stream health and recovery”) for details.
Fields§
§private_key: Option<String>Optional private key for authenticated endpoints.
base_url_ws: Option<String>Override for the WebSocket URL.
base_url_http: Option<String>Override for the HTTP info URL.
proxy_url: Option<String>Optional proxy URL for HTTP and WebSocket transports.
environment: HyperliquidEnvironmentThe target environment (mainnet or testnet).
http_timeout_secs: u64HTTP timeout in seconds.
ws_timeout_secs: u64WebSocket timeout in seconds.
stale_stream_receive_timeout_secs: u64Receive-age threshold in seconds for warning about stale market-data streams. Choose a value above the instrument’s expected quiet period. Set to 0 to disable the stream health monitor.
stream_health_check_interval_secs: u64Interval in seconds for running market-data stream health checks. Set to 0 to disable the stream health monitor.
stale_stream_warning_cooldown_secs: u64Cooldown in seconds between stale warnings for the same market-data stream.
stale_stream_recovery_enabled: boolEnables automated stale-stream recovery. Off by default: the stream health monitor warns only and never changes subscriptions.
stale_stream_recovery_cooldown_secs: u64Cooldown in seconds between recovery actions for the same market-data stream. Must be positive for recovery to run.
stale_stream_max_targeted_resubscribes: u32Targeted resubscribe attempts for a stale stream before escalating to a full WebSocket reconnect.
update_instruments_interval_mins: u64Interval for refreshing instruments in minutes.
transport_backend: TransportBackendWebSocket transport backend (Sockudo by default; Tungstenite when
the transport-sockudo feature is disabled).
Implementations§
Source§impl HyperliquidDataClientConfig
impl HyperliquidDataClientConfig
Sourcepub fn builder() -> HyperliquidDataClientConfigBuilder
pub fn builder() -> HyperliquidDataClientConfigBuilder
Create an instance of HyperliquidDataClientConfig using the builder syntax
Source§impl HyperliquidDataClientConfig
impl HyperliquidDataClientConfig
Trait Implementations§
Source§impl Clone for HyperliquidDataClientConfig
impl Clone for HyperliquidDataClientConfig
Source§fn clone(&self) -> HyperliquidDataClientConfig
fn clone(&self) -> HyperliquidDataClientConfig
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 HyperliquidDataClientConfig
impl Debug for HyperliquidDataClientConfig
Source§impl<'de> Deserialize<'de> for HyperliquidDataClientConfigwhere
HyperliquidDataClientConfig: Default,
impl<'de> Deserialize<'de> for HyperliquidDataClientConfigwhere
HyperliquidDataClientConfig: 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>,
Auto Trait Implementations§
impl Freeze for HyperliquidDataClientConfig
impl RefUnwindSafe for HyperliquidDataClientConfig
impl Send for HyperliquidDataClientConfig
impl Sync for HyperliquidDataClientConfig
impl Unpin for HyperliquidDataClientConfig
impl UnsafeUnpin for HyperliquidDataClientConfig
impl UnwindSafe for HyperliquidDataClientConfig
Blanket Implementations§
impl<T> Allocation for T
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 T
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>,
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
Source§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