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 cancel_on_disconnect: bool,
    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

cancel_on_disconnect: bool

Ask the server to cancel this session’s open quotes when it disconnects; the session terminates if the server does not enable it. Applies only to the quote endpoint.

gap_policy: GapPolicy

Implementations

impl ManagedWsConfig

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

Authenticate with a local key. The signer’s own public key is the maker identity unless Self::with_auth_pubkey names a delegating owner.

pub const fn low_latency(self) -> Self

Short liveness deadlines, larger buffers and reconnect on inbound gaps.

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

pub const fn with_cancel_on_disconnect(self, enabled: bool) -> Self

pub fn with_auth_pubkey(self, pubkey: impl Into<String>) -> Self

Set the maker owner’s identity when using a delegated auth signer. The configured signer still signs the challenge.

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>, ) -> Self

Configure an asynchronous Ed25519 signer.

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.