Struct DataFeed

pub struct DataFeed { /* private fields */ }

Main client for interacting with the Pyth Network API

Implementations

impl DataFeed

pub fn new(subscriptions: Subscriptions) -> Self

Create a new DataFeed instance with the given subscriptions

pub async fn on_ready<F>(&self, callback: F)

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

Initialize the data feed and call the callback when ready

Arguments

• callback - Function to call when the data feed is ready with config data

pub async fn search_symbols<F>( &self, user_input: &str, _exchange: &str, _symbol_type: &str, on_result_ready_callback: F, )

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

Search for symbols matching the given query

Arguments

• user_input - Search query string
• exchange - Exchange filter (currently unused)
• symbol_type - Symbol type filter (currently unused)
• on_result_ready_callback - Callback for when search results are ready

pub async fn resolve_symbol<F1, F2>( &self, symbol_name: &str, on_symbol_resolved_callback: F1, on_resolve_error_callback: F2, )

where F1: FnMut(Value) + Send + 'static, F2: FnMut(&str) + Send + 'static,

Resolve symbol information for the given symbol name

Arguments

• symbol_name - Name of the symbol to resolve
• on_symbol_resolved_callback - Callback for successful resolution
• on_resolve_error_callback - Callback for resolution errors

pub async fn get_bars<F1, F2>( &self, symbol_info: &SymbolInfo, resolution: &str, period_params: &PeriodParams, on_history_callback: F1, _on_error_callback: F2, )

where F1: FnMut(Vec<Bar>, bool) + Send + 'static, F2: FnMut(Error) + Send + 'static,

Get historical bar data for a symbol

Arguments

• symbol_info - Symbol information
• resolution - Time resolution (e.g., “1D”, “1H”)
• period_params - Time period parameters
• on_history_callback - Callback for historical data
• on_error_callback - Callback for errors

pub async fn subscribe_bars( &self, symbol_info: SymbolInfo, resolution: String, on_realtime_callback: UnboundedSender<Bar>, subscriber_uid: String, _on_reset_cache_needed_callback: Option<fn()>, )

Subscribe to real-time bar updates for a symbol

Arguments

• symbol_info - Symbol information
• resolution - Time resolution
• on_realtime_callback - Channel for receiving bar updates
• subscriber_uid - Unique identifier for this subscription
• on_reset_cache_needed_callback - Optional callback for cache resets

pub async fn unsubscribe_bars(&self, subscriber_uid: &str)

Unsubscribe from bar updates

Arguments

• subscriber_uid - Unique identifier of the subscription to remove

pub fn get_last_bar(&self, ticker: &str) -> Option<Bar>

Get the cached last bar for a symbol, if available

pub fn set_last_bar(&self, ticker: String, bar: Bar)

Manually set the last bar for a symbol in the cache

Trait Implementations

impl Clone for DataFeed

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.