Struct ManagedWsConfig 

pub struct ManagedWsConfig {

    pub url: String,
    pub endpoint: MakerWsEndpoint,
    pub reconnect_delay: Duration,
    pub max_reconnect_delay: Duration,
    pub reconnect_jitter_ratio: f64,
    pub max_reconnect_attempts: u64,
    pub connect_timeout: Duration,
    pub ping_interval: Duration,
    pub auth_timeout: Duration,
    pub readiness_timeout: Duration,
    pub write_timeout: Duration,
    pub command_buffer: usize,
    pub broadcast_buffer: usize,
    pub max_batch_quotes: usize,
    pub max_outbound_message_size: usize,
    pub ws_read_timeout: Option<Duration>,
    pub pong_timeout: Duration,
    pub transport: WsTransportConfig,
    pub max_pending_awaits: usize,
    pub gap_policy: GapPolicy,
    /* private fields */
}

Fields

url: String

endpoint: MakerWsEndpoint

reconnect_delay: Duration

max_reconnect_delay: Duration

reconnect_jitter_ratio: f64

Symmetric reconnect jitter ratio in the inclusive range 0.0..=1.0.

max_reconnect_attempts: u64

Reconnects after the initial attempt. Zero means retry forever.

connect_timeout: Duration

Managed handshake deadline. Overrides transport.connect_timeout for this runtime.

ping_interval: Duration

auth_timeout: Duration

readiness_timeout: Duration

Deadline for initial subscription acknowledgement and recovery reads. For live subscription changes, starts after the frame is written.

write_timeout: Duration

command_buffer: usize

broadcast_buffer: usize

max_batch_quotes: usize

Maximum number of quotes accepted in one outbound batch.

max_outbound_message_size: usize

Maximum serialized size of one outbound client message.

ws_read_timeout: Option<Duration>

pong_timeout: Duration

transport: WsTransportConfig

max_pending_awaits: usize

gap_policy: GapPolicy

Implementations

impl ManagedWsConfig

pub fn new( url: impl Into<String>, hello: HelloData, signer: Arc<dyn SignerLike + Send + Sync>, auth_pubkey: impl Into<Address32>, ) -> Self

Authenticate as maker owner auth_pubkey; signer must be its registered quote-signing key (which may equal the owner key).

pub const fn low_latency(self) -> Self

Short liveness deadlines, a larger command buffer and reconnect on inbound gaps.

pub const fn with_gap_policy(self, policy: GapPolicy) -> Self

pub const fn with_endpoint(self, endpoint: MakerWsEndpoint) -> Self

pub fn with_initial_subscribe(self, subscribe: SubscribeData) -> Self

pub fn validate(&self) -> Result<(), ManagedWsConfigError>

Validate task capacities and deadlines before spawning the session.

impl ManagedWsConfig

pub fn new_async( url: impl Into<String>, hello: HelloData, signer: Arc<dyn AsyncSignerLike>, auth_pubkey: impl Into<Address32>, ) -> Self

Authenticate as maker owner auth_pubkey; the async signer must be its registered quote-signing key.

Trait Implementations

impl Clone for ManagedWsConfig

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.