Struct ConnectorCfg 

pub struct ConnectorCfg {

    pub orders_capacity: usize,
    pub pnl_capacity: usize,
    pub marketdata_capacity: usize,
    pub backoff_min: Duration,
    pub backoff_max: Duration,
    pub heartbeat_timeout: Duration,
    pub marketdata_idle_unsubscribe: Duration,
    pub event_log: Option<Arc<EventLog>>,
    pub retention: RetentionPolicy,
    pub prune_every: Duration,
    pub resubscribe_min: Duration,
    pub resubscribe_max: Duration,
    pub session_check_every: Duration,
    pub backoff_reset_after: Duration,
    pub quiet_after_rounds: u32,
}

Configurable knobs for the connector.

Fields

orders_capacity: usize

Capacity of the orders ring.

pnl_capacity: usize

Capacity of the pnl ring.

marketdata_capacity: usize

Per-conid market-data ring capacity.

backoff_min: Duration

Min reconnect backoff.

backoff_max: Duration

Max reconnect backoff.

heartbeat_timeout: Duration

If no frame arrives in this long, the connector tears the socket down and reconnects (assumes the socket is dead, not idle).

marketdata_idle_unsubscribe: Duration

Idle market-data subs auto-unsubscribe after this long with no ensure_market_data call (P2 — currently unused, plumbed for forward compatibility).

event_log: Option<Arc<EventLog>>

Optional sqlite-backed historical event log. When set, every pushed event is also appended here so /events/{topic}/history can serve reads beyond ring capacity.

retention: RetentionPolicy

Retention policy used by the periodic prune task.

prune_every: Duration

How often to run the prune task. Defaults to once per hour.

resubscribe_min: Duration

First retry delay after CPAPI refuses a standing subscription.

resubscribe_max: Duration

Retry delay ceiling. A sor+{} every five minutes is a harmless ask of a Gateway that keeps saying no; the fund’s confirmer no longer depends on it, but a healthy stream is still the fast path.

session_check_every: Duration

How often to ask /tickle whether the Gateway session the socket was opened under is still the current one.

backoff_reset_after: Duration

A connection that stayed up at least this long resets the reconnect backoff to backoff_min. Shorter-lived ones keep doubling it, so a socket that connects and dies at once cannot spin.

quiet_after_rounds: u32

Resubscribe rounds a standing topic may go unanswered — no frame, no refusal — before it is reported quiet and no longer re-asked. 0 re-asks forever (the behaviour before this knob existed).

Trait Implementations

impl Clone for ConnectorCfg

fn clone(&self) -> ConnectorCfg

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ConnectorCfg

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for ConnectorCfg

fn default() -> Self

Returns the “default value” for a type.