IndexerRpcClient

data_anchor_api

Trait IndexerRpcClient 

Source 
pub trait IndexerRpcClient: SubscriptionClientT {
    // Provided methods
    fn health<'life0, 'async_trait>(
        &'life0 self,
    ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>
       where Self: Sync + 'async_trait,
             'life0: 'async_trait { ... }
    fn get_blobs<'life0, 'async_trait>(
        &'life0 self,
        blober: PubkeyFromStr,
        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: PubkeyFromStr,
        time_range: Option<TimeRange>,
    ) -> 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: PubkeyFromStr,
        network_name: String,
        time_range: Option<TimeRange>,
    ) -> 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_network<'life0, 'async_trait>(
        &'life0 self,
        network_name: String,
        time_range: Option<TimeRange>,
    ) -> 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_namespace_for_payer<'life0, 'async_trait>(
        &'life0 self,
        namespace: String,
        payer: Option<PubkeyFromStr>,
        time_range: Option<TimeRange>,
    ) -> Pin<Box<dyn Future<Output = Result<Vec<Vec<u8>>, Error>> + Send + 'async_trait>>
       where Self: Sync + 'async_trait,
             'life0: 'async_trait { ... }
    fn get_payers_by_network<'life0, 'async_trait>(
        &'life0 self,
        network_name: String,
    ) -> Pin<Box<dyn Future<Output = Result<Vec<PubkeyFromStr>, Error>> + Send + 'async_trait>>
       where Self: Sync + 'async_trait,
             'life0: 'async_trait { ... }
    fn get_proof<'life0, 'async_trait>(
        &'life0 self,
        blober: PubkeyFromStr,
        slot: u64,
    ) -> Pin<Box<dyn Future<Output = Result<Option<CompoundInclusionProof>, Error>> + Send + 'async_trait>>
       where Self: Sync + 'async_trait,
             'life0: 'async_trait { ... }
    fn get_proof_for_blob<'life0, 'async_trait>(
        &'life0 self,
        blob_address: PubkeyFromStr,
    ) -> Pin<Box<dyn Future<Output = Result<Option<CompoundInclusionProof>, Error>> + Send + 'async_trait>>
       where Self: Sync + 'async_trait,
             'life0: 'async_trait { ... }
    fn subscribe_blob_finalization<'life0, 'async_trait>(
        &'life0 self,
        blobers: HashSet<PubkeyFromStr>,
    ) -> Pin<Box<dyn Future<Output = Result<Subscription<(Pubkey, u64)>, 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 health<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>
where Self: Sync + 'async_trait, 'life0: 'async_trait,

Check the health of the RPC server. Returns an error if the server is not healthy.

Source

fn get_blobs<'life0, 'async_trait>( &'life0 self, blober: PubkeyFromStr, 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: PubkeyFromStr, time_range: Option<TimeRange>, ) -> 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: PubkeyFromStr, network_name: String, time_range: Option<TimeRange>, ) -> 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_blobs_by_network<'life0, 'async_trait>( &'life0 self, network_name: String, time_range: Option<TimeRange>, ) -> 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 network name 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_namespace_for_payer<'life0, 'async_trait>( &'life0 self, namespace: String, payer: Option<PubkeyFromStr>, time_range: Option<TimeRange>, ) -> 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 namespace 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_payers_by_network<'life0, 'async_trait>( &'life0 self, network_name: String, ) -> Pin<Box<dyn Future<Output = Result<Vec<PubkeyFromStr>, Error>> + Send + 'async_trait>>
where Self: Sync + 'async_trait, 'life0: 'async_trait,

Retrieve a list of payers for a given network name. Returns an error if there was a database or RPC failure, and an empty list if no payers were found.

Source

fn get_proof<'life0, 'async_trait>( &'life0 self, blober: PubkeyFromStr, slot: u64, ) -> Pin<Box<dyn Future<Output = Result<Option<CompoundInclusionProof>, 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: PubkeyFromStr, ) -> Pin<Box<dyn Future<Output = Result<Option<CompoundInclusionProof>, 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 subscribe_blob_finalization<'life0, 'async_trait>( &'life0 self, blobers: HashSet<PubkeyFromStr>, ) -> Pin<Box<dyn Future<Output = Result<Subscription<(Pubkey, u64)>, 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,