Struct MarketDataConfig 

pub struct MarketDataConfig {
    pub bybit: BybitConfig,
    pub source: Arc<str>,
    pub reconnect_min: Duration,
    pub reconnect_max: Duration,
    pub subscribe_ack_timeout: Duration,
}

Settings of MarketDataConnector.

Examples

use std::time::Duration;
use brokapi_bybit_protocol::config::BybitConfig;
use brokapi_bybit::MarketDataConfig;

let mut cfg = MarketDataConfig::new(BybitConfig::new("key", "secret"), "bybit-md");
assert_eq!(&*cfg.source, "bybit-md");
// Wait at most 10 seconds between reconnects instead of the default 30.
cfg.reconnect_max = Duration::from_secs(10);

Fields

bybit: BybitConfig

Client settings of the Bybit API: key pair, contour, receive window, endpoints.

source: Arc<str>

Envelope source label, e.g. "bybit-md".

reconnect_min: Duration

Pause before the first reconnect of the WebSocket, doubling up to reconnect_max (default 0.5 s, as at the other brokers).

reconnect_max: Duration

Upper bound of the pause (default 30 s). The pause returns to reconnect_min once a connection has lived 10 seconds.

subscribe_ack_timeout: Duration

How long a subscribe_* call waits for the broker to confirm the subscription (default 3 s). The call returns when the broker has confirmed: what happens after that is delivered. A refusal is returned as Rejected. If nothing comes in time, the call fails with Transport and the subscription is taken back, so the call can be repeated.

Implementations

impl MarketDataConfig

pub fn new(bybit: BybitConfig, source: impl Into<Arc<str>>) -> Self

Creates a config with the default reconnect pauses (0.5 s up to 30 s).

source is the label put in every Envelope this connector emits, so a bot with several connectors can tell them apart.

Trait Implementations

impl Clone for MarketDataConfig

fn clone(&self) -> MarketDataConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for MarketDataConfig

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

Formats the value using the given formatter.