Struct PythLazerHistoryClient 

pub struct PythLazerHistoryClient { /* private fields */ }

Client to the history service API.

Implementations

impl PythLazerHistoryClient

pub fn new(config: PythLazerHistoryClientConfig) -> Self

pub async fn all_symbols_metadata(&self) -> Result<Vec<SymbolMetadata>>

Fetch current metadata for all symbols.

pub async fn all_symbols_metadata_stream( &self, ) -> Result<impl Stream<Item = Vec<SymbolMetadata>> + Unpin>

Creates a fault-tolerant stream that requests the list of symbols and yields new items when a change of value occurs.

Returns an error if the initial fetch failed. On a successful return, the channel will always contain the initial data that can be fetched immediately from the returned stream. You should continuously poll the stream to receive updates.

pub async fn state(&self, params: GetStateParams) -> Result<State>

Fetch a partial state snapshot containing data specified in params.

pub async fn state_stream( &self, params: GetStateParams, ) -> Result<impl Stream<Item = State> + Unpin>

Fetch a part of the current state specified by params.

Creates a fault-tolerant stream that requests a partial state snapshot containing data specified in params. It yields new items when a change of value occurs.

Returns an error if the initial fetch failed. On a successful return, the stream will always contain the initial data that can be fetched immediately from the returned stream. You should continuously poll the stream to receive updates.

Trait Implementations

impl Clone for PythLazerHistoryClient

fn clone(&self) -> PythLazerHistoryClient

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for PythLazerHistoryClient

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

Formats the value using the given formatter.