Struct MarketDataConfig 

pub struct MarketDataConfig {
    pub tbank: TbankConfig,
    pub source: Arc<str>,
    pub ping_interval: Duration,
}

Market data connector config. Not tied to an account: one per broker (token) is enough.

Build it with MarketDataConfig::new and change the public fields if needed.

Examples

use brokapi_tbank::MarketDataConfig;
use brokapi_tbank_protocol::TbankConfig;

let mut cfg = MarketDataConfig::new(TbankConfig::sandbox("t.my-token"), "tbank-md");
cfg.ping_interval = std::time::Duration::from_secs(10);
assert_eq!(&*cfg.source, "tbank-md");

Fields

tbank: TbankConfig

Endpoint, token and timeouts of the API. tbank.account_id is ignored by market data.

source: Arc<str>

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

ping_interval: Duration

Server ping period on the stream. T-Bank accepts 5 s to 180 s: a value outside that range is brought into it, both for the request and for the silence limit. A stream silent for three periods is treated as dead and reconnected. Default 30 s.

Implementations

impl MarketDataConfig

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

A config with the default ping period (30 s).

source labels every Envelope this connector emits, so that you can tell connectors apart when they write into one channel.

Examples

use brokapi_tbank::MarketDataConfig;
use brokapi_tbank_protocol::TbankConfig;

let cfg = MarketDataConfig::new(TbankConfig::production("t.my-token"), "tbank-md");
assert_eq!(&*cfg.source, "tbank-md");

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.