Struct MarketDataConfig 

pub struct MarketDataConfig {
    pub api: FinamApiConfig,
    pub source: Arc<str>,
    pub subscribe_ack_timeout: Duration,
}

Market data connector config. Not bound to an account.

Used with MarketDataConnector::start.

Fields

api: FinamApiConfig

Credentials and endpoint.

source: Arc<str>

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

subscribe_ack_timeout: Duration

How long subscribe_* waits for the stream to open (default 3 seconds).

The call returns as soon as the broker has opened the stream: what happens after that is delivered. A refusal (unknown symbol, no permission) is returned as Rejected. A stream that has not opened in time leaves the subscription connecting and the call returns Ok, unlike the other brokers: Finam is gRPC, and a gRPC server may send the headers of a quiet stream only together with its first message, so a healthy stream of orders can look “not open” until the first order. Until the stream is open, events of the broker are not delivered: check MarketDataConnector::sub_status. Not verified against the live server; if it sends the headers at once, this will become an error like at the other brokers.

Implementations

impl MarketDataConfig

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

Config with default settings. source labels every envelope the connector emits.

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.