Struct HermesClient

pub struct HermesClient { /* private fields */ }

Implementations

impl HermesClient

pub fn new(base_url: impl Into<String>) -> Self

pub async fn get_latest_price_feeds( &self, ids: &[&str], ) -> Result<Vec<RpcPriceFeed>, Error>

Get the latest price updates by price feed id.

pub async fn get_price_feeds_metadata( &self, query: Option<&str>, asset_type: Option<&str>, ) -> Result<Vec<PriceFeedMetadata>, Error>

This endpoint fetches all price feeds from the Pyth network. It can be filtered by asset type and query string.

Arguments

• query - If provided results will be filtered for price feeds whose symbol contains the query string
• asset_type - If provides filter by asset type. Values are crypto, equity, fx, metal, rates

pub async fn get_price_updates_by_time( &self, publish_time: i64, ids: &[&str], ) -> Result<PriceUpdate, Error>

Get the latest price updates by price feed id, with a publish time greater than publish_time

Arguments

• publish_time - Only return price feed updates that are greater than or equal to this timestamp

pub async fn get_latest_twaps( &self, window_seconds: u64, ids: &[&str], ) -> Result<TwapsResponse, Error>

Get the latest TWAP by price feed id with a custom time window.

Arguments

• window_seconds - Time period in seconds used to calculate the TWAP, ending at current time

pub async fn get_latest_publisher_stake_caps( &self, ) -> Result<LatestPublisherStakeCapsUpdateDataResponse, Error>

Gets the most recent publisher stake caps update data

pub async fn stream_price_updates<F>( &self, ids: Vec<String>, on_event: F, ) -> Result<JoinHandle<()>, Error>

where F: FnMut(ParsedPriceUpdate) + Send + 'static,

Spawns a task which streams price updates from the hermes api

Returns

JoinHandle which can be used to abort the spawned task