data_anchor_api

Trait IndexerRpcClient

Source 
pub trait IndexerRpcClient: SubscriptionClientT {
    // Provided methods
    fn get_blobs<'life0, 'async_trait>(
        &'life0 self,
        blober: Pubkey,
        slot: u64,
    ) -> Pin<Box<dyn Future<Output = Result<Option<Vec<Vec<u8>>>, Error>> + Send + 'async_trait>>
       where Self: Sync + 'async_trait,
             'life0: 'async_trait { ... }
    fn get_blobs_by_blober<'life0, 'async_trait>(
        &'life0 self,
        blober: BlobsByBlober,
    ) -> Pin<Box<dyn Future<Output = Result<Vec<Vec<u8>>, Error>> + Send + 'async_trait>>
       where Self: Sync + 'async_trait,
             'life0: 'async_trait { ... }
    fn get_blobs_by_payer<'life0, 'async_trait>(
        &'life0 self,
        payer: BlobsByPayer,
    ) -> Pin<Box<dyn Future<Output = Result<Vec<Vec<u8>>, Error>> + Send + 'async_trait>>
       where Self: Sync + 'async_trait,
             'life0: 'async_trait { ... }
    fn get_proof<'life0, 'async_trait>(
        &'life0 self,
        blober: Pubkey,
        slot: u64,
    ) -> Pin<Box<dyn Future<Output = Result<Option<CompoundProof>, Error>> + Send + 'async_trait>>
       where Self: Sync + 'async_trait,
             'life0: 'async_trait { ... }
    fn get_proof_for_blob<'life0, 'async_trait>(
        &'life0 self,
        blob_address: Pubkey,
    ) -> Pin<Box<dyn Future<Output = Result<Option<CompoundProof>, Error>> + Send + 'async_trait>>
       where Self: Sync + 'async_trait,
             'life0: 'async_trait { ... }
    fn add_blobers<'life0, 'async_trait>(
        &'life0 self,
        blobers: HashSet<BloberData>,
    ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>
       where Self: Sync + 'async_trait,
             'life0: 'async_trait { ... }
    fn remove_blobers<'life0, 'async_trait>(
        &'life0 self,
        blobers: HashSet<Pubkey>,
    ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>
       where Self: Sync + 'async_trait,
             'life0: 'async_trait { ... }
    fn subscribe_blob_finalization<'life0, 'async_trait>(
        &'life0 self,
        blobers: HashSet<Pubkey>,
    ) -> Pin<Box<dyn Future<Output = Result<Subscription<(Pubkey, Slot)>, Error>> + Send + 'async_trait>>
       where Self: Sync + 'async_trait,
             'life0: 'async_trait { ... }
}
Expand description

Client implementation for the IndexerRpc RPC API.

Provided Methods§

Source

fn get_blobs<'life0, 'async_trait>( &'life0 self, blober: Pubkey, slot: u64, ) -> Pin<Box<dyn Future<Output = Result<Option<Vec<Vec<u8>>>, Error>> + Send + 'async_trait>>
where Self: Sync + 'async_trait, 'life0: 'async_trait,

Retrieve a list of blobs for a given slot and blober pubkey. Returns an error if there was a database or RPC failure, and None if the slot has not been completed yet. If the slot is completed, an empty list will be returned.

Source

fn get_blobs_by_blober<'life0, 'async_trait>( &'life0 self, blober: BlobsByBlober, ) -> Pin<Box<dyn Future<Output = Result<Vec<Vec<u8>>, Error>> + Send + 'async_trait>>
where Self: Sync + 'async_trait, 'life0: 'async_trait,

Retrieve a list of blobs for a given blober pubkey and time range. Returns an error if there was a database or RPC failure, and an empty list if no blobs were found.

Source

fn get_blobs_by_payer<'life0, 'async_trait>( &'life0 self, payer: BlobsByPayer, ) -> Pin<Box<dyn Future<Output = Result<Vec<Vec<u8>>, Error>> + Send + 'async_trait>>
where Self: Sync + 'async_trait, 'life0: 'async_trait,

Retrieve a list of blobs for a given payer pubkey, network ID, and time range. Returns an error if there was a database or RPC failure, and an empty list if no blobs were found.

Source

fn get_proof<'life0, 'async_trait>( &'life0 self, blober: Pubkey, slot: u64, ) -> Pin<Box<dyn Future<Output = Result<Option<CompoundProof>, Error>> + Send + 'async_trait>>
where Self: Sync + 'async_trait, 'life0: 'async_trait,

Retrieve a proof for a given slot and blober pubkey. Returns an error if there was a database or RPC failure, and None if the slot has not been completed yet.

Source

fn get_proof_for_blob<'life0, 'async_trait>( &'life0 self, blob_address: Pubkey, ) -> Pin<Box<dyn Future<Output = Result<Option<CompoundProof>, Error>> + Send + 'async_trait>>
where Self: Sync + 'async_trait, 'life0: 'async_trait,

Retrieve a compound proof that covers a particular blob. Returns an error if there was a database or RPC failure, and None if the blob does not exist.

Source

fn add_blobers<'life0, 'async_trait>( &'life0 self, blobers: HashSet<BloberData>, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>
where Self: Sync + 'async_trait, 'life0: 'async_trait,

Add a list of blober PDA addresses to the list of tracked blobers.

Source

fn remove_blobers<'life0, 'async_trait>( &'life0 self, blobers: HashSet<Pubkey>, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>
where Self: Sync + 'async_trait, 'life0: 'async_trait,

Remove a list of blober PDA addresses from the list of tracked blobers.

Source

fn subscribe_blob_finalization<'life0, 'async_trait>( &'life0 self, blobers: HashSet<Pubkey>, ) -> Pin<Box<dyn Future<Output = Result<Subscription<(Pubkey, Slot)>, Error>> + Send + 'async_trait>>
where Self: Sync + 'async_trait, 'life0: 'async_trait,

Listen to blob finalization events from specified blobers. This will return a stream of slots and blober PDAs that have finalized blobs. The stream will be closed when the RPC server is shut down.

Dyn Compatibility§

This trait is not dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety", so this trait is not object safe.

Implementors§

Source§

impl<TypeJsonRpseeInteral> IndexerRpcClient for TypeJsonRpseeInteral
where TypeJsonRpseeInteral: SubscriptionClientT,