Struct EngineScope 

pub struct EngineScope<'a> { /* private fields */ }

Основные пагинаторы и типы контекстов блокирующего API. Блокирующие HTTP-клиенты ISS API. Блокирующий владеющий контекст для engine.

Implementations

impl<'a> OwnedEngineScope<'a>

pub fn engine(&self) -> &EngineName

Имя торгового движка текущего контекста.

Examples found in repository

examples/actual_indexes_dump.rs (line 128)

fn load_security_snapshots(
    moex_client: &Client,
    wanted_secids: &HashSet<SecId>,
) -> Result<(HashMap<SecId, ResolvedSnapshot>, Vec<SecId>), ExampleError> {
    let stock_scope = moex_client
        .stock()
        .expect("stock engine literal must be valid");
    let markets = with_retry(retry_policy(), || stock_scope.markets())?;
    let mut snapshots = HashMap::with_capacity(wanted_secids.len());

    'markets: for market in markets {
        let boards = with_retry(retry_policy(), || {
            moex_client.boards(stock_scope.engine(), market.name())
        })?;

        for board in boards.into_iter().filter(|board| board.is_traded()) {
            let board_snapshots = load_board_snapshots_all_pages(
                moex_client,
                stock_scope.engine().as_str(),
                market.name().as_str(),
                board.boardid().as_str(),
            )?;

            for snapshot in board_snapshots {
                if !wanted_secids.contains(snapshot.secid()) {
                    continue;
                }

                snapshots
                    .entry(snapshot.secid().clone())
                    .or_insert_with(|| ResolvedSnapshot {
                        market: market.name().as_str().to_owned().into_boxed_str(),
                        board: board.boardid().as_str().to_owned().into_boxed_str(),
                        lot_size: snapshot.lot_size(),
                        last: snapshot.last(),
                    });
            }

            if snapshots.len() == wanted_secids.len() {
                break 'markets;
            }
        }
    }

    let missing_mapping = wanted_secids
        .iter()
        .filter(|secid| !snapshots.contains_key(*secid))
        .cloned()
        .collect();

    Ok((snapshots, missing_mapping))
}

pub fn markets(&self) -> Result<Vec<Market>, MoexError>

Получить доступные рынки (markets) для текущего движка.

Examples found in repository

examples/actual_indexes_dump.rs (line 123)

fn load_security_snapshots(
    moex_client: &Client,
    wanted_secids: &HashSet<SecId>,
) -> Result<(HashMap<SecId, ResolvedSnapshot>, Vec<SecId>), ExampleError> {
    let stock_scope = moex_client
        .stock()
        .expect("stock engine literal must be valid");
    let markets = with_retry(retry_policy(), || stock_scope.markets())?;
    let mut snapshots = HashMap::with_capacity(wanted_secids.len());

    'markets: for market in markets {
        let boards = with_retry(retry_policy(), || {
            moex_client.boards(stock_scope.engine(), market.name())
        })?;

        for board in boards.into_iter().filter(|board| board.is_traded()) {
            let board_snapshots = load_board_snapshots_all_pages(
                moex_client,
                stock_scope.engine().as_str(),
                market.name().as_str(),
                board.boardid().as_str(),
            )?;

            for snapshot in board_snapshots {
                if !wanted_secids.contains(snapshot.secid()) {
                    continue;
                }

                snapshots
                    .entry(snapshot.secid().clone())
                    .or_insert_with(|| ResolvedSnapshot {
                        market: market.name().as_str().to_owned().into_boxed_str(),
                        board: board.boardid().as_str().to_owned().into_boxed_str(),
                        lot_size: snapshot.lot_size(),
                        last: snapshot.last(),
                    });
            }

            if snapshots.len() == wanted_secids.len() {
                break 'markets;
            }
        }
    }

    let missing_mapping = wanted_secids
        .iter()
        .filter(|secid| !snapshots.contains_key(*secid))
        .cloned()
        .collect();

    Ok((snapshots, missing_mapping))
}

pub fn turnovers(&self) -> Result<Vec<Turnover>, MoexError>

Получить обороты (turnovers) для текущего движка.

pub fn market<M>( self, market: M, ) -> Result<OwnedMarketScope<'a>, ParseMarketNameError>

where M: TryInto<MarketName>, M::Error: Into<ParseMarketNameError>,

Зафиксировать рынок внутри текущего engine.

pub fn shares(self) -> Result<OwnedMarketScope<'a>, ParseMarketNameError>

Сокращение для часто используемого рынка shares.

Trait Implementations

impl<'a> Clone for OwnedEngineScope<'a>

fn clone(&self) -> OwnedEngineScope<'a>

Returns a duplicate of the value.

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

Performs copy-assignment from source.