Struct PythPullOracle

pub struct PythPullOracle<C> { /* private fields */ }

Pyth Pull Oracle.

Implementations

impl<S, C> PythPullOracle<C>

where C: Deref<Target = S> + Clone, S: Signer,

pub fn try_new(client: &Client<C>) -> Result<Self>

Create a new PythPullOracle client from Client.

Trait Implementations

impl<S, C> PythPullOracleOps<C> for PythPullOracle<C>

where C: Deref<Target = S> + Clone, S: Signer,

fn pyth(&self) -> &Program<C>

Get Pyth Program.

fn wormhole(&self) -> &Program<C>

Get Wormhole Program.

fn with_pyth_prices<'a, S, It, Fut>( &'a self, ctx: &'a PythPullOracleContext, update: &'a PriceUpdate, consume: impl FnOnce(Prices) -> Fut, ) -> impl Future<Output = Result<WithPythPrices<'a, C>>>

where C: Deref<Target = S> + Clone + 'a, S: Signer, It: IntoIterator<Item = TransactionBuilder<'a, C>>, Fut: Future<Output = Result<It>>,

Create transactions to post price updates and consume the prices.

fn with_pyth_price_updates<'a, S, It, Fut>( &'a self, ctx: &'a PythPullOracleContext, updates: impl IntoIterator<Item = &'a BinaryPriceUpdate>, consume: impl FnOnce(Prices) -> Fut, ) -> impl Future<Output = Result<WithPythPrices<'a, C>>>

where C: Deref<Target = S> + Clone + 'a, S: Signer, It: IntoIterator<Item = TransactionBuilder<'a, C>>, Fut: Future<Output = Result<It>>,

Create transactions to post price updates and consume the prices.

fn execute_with_pyth_price_updates<'a, 'exec, T, S>( &'exec self, updates: impl IntoIterator<Item = &'a BinaryPriceUpdate>, execute: &mut T, compute_unit_price_micro_lamports: Option<u64>, skip_preflight: bool, enable_tracing: bool, ) -> impl Future<Output = Result<()>>

where C: Deref<Target = S> + Clone + 'exec, S: Signer, T: ExecuteWithPythPrices<'exec, C>,

Execute with pyth price updates.