Struct BloberClient

pub struct BloberClient { /* private fields */ }

Implementations

impl BloberClient

pub fn builder() -> BloberClientBuilder

Create an instance of BloberClient using the builder syntax

impl BloberClient

pub fn rpc_client(&self) -> Arc<RpcClient>

Returns the underlaying RpcClient.

pub fn payer(&self) -> Arc<Keypair>

Returns the transaction payer Keypair.

pub async fn initialize_blober( &self, fee_strategy: FeeStrategy, namespace: &str, timeout: Option<Duration>, ) -> BloberClientResult<Vec<SuccessfulTransaction<TransactionType>>>

Initializes a new Blober PDA account.

pub async fn close_blober( &self, fee_strategy: FeeStrategy, namespace: &str, timeout: Option<Duration>, ) -> BloberClientResult<Vec<SuccessfulTransaction<TransactionType>>>

Closes a Blober PDA account.

pub async fn upload_blob( &self, blob_data: &[u8], fee_strategy: FeeStrategy, namespace: &str, timeout: Option<Duration>, ) -> BloberClientResult<Vec<SuccessfulTransaction<TransactionType>>>

Uploads a blob of data with the given Blober PDA account. Under the hood it creates a new data_anchor_blober::state::blob::Blob PDA which stores a incremental hash of the chunks from the blob data. On completion of the blob upload, the blob PDA gets closed sending it’s funds back to the BloberClient::payer. If the blob upload fails, the blob PDA gets discarded and the funds also get sent to the BloberClient::payer.

pub async fn discard_blob( &self, fee_strategy: FeeStrategy, blob: Pubkey, namespace: &str, timeout: Option<Duration>, ) -> BloberClientResult<Vec<SuccessfulTransaction<TransactionType>>>

Discards a data_anchor_blober::state::blob::Blob PDA account registered with the provided Blober PDA account.

pub async fn estimate_fees( &self, blob_size: usize, blober: Pubkey, priority: Priority, ) -> BloberClientResult<Fee>

Estimates fees for uploading a blob of the size blob_size with the given priority. This whole functions is basically a simulation that doesn’t run anything. Instead of executing transactions, it just sums the expected fees and number of signatures.

The data_anchor_blober::state::blob::Blob PDA account is always newly created, so for estimating compute fees we don’t even need the real keypair, any unused pubkey will do.

pub async fn get_ledger_blobs_from_signatures( &self, namespace: &str, payer_pubkey: Option<Pubkey>, signatures: Vec<Signature>, ) -> BloberClientResult<Vec<u8>>

Returns the raw blob data from the ledger for the given signatures.

pub async fn get_ledger_blobs( &self, slot: u64, namespace: &str, payer_pubkey: Option<Pubkey>, lookback_slots: Option<u64>, ) -> BloberClientResult<Vec<Vec<u8>>>

Fetches all blobs finalized in a given slot from the ledger.

pub async fn get_blobs( &self, slot: u64, namespace: &str, payer_pubkey: Option<Pubkey>, ) -> BloberClientResult<Vec<Vec<u8>>>

Fetches all blobs for a given slot from the IndexerRpcClient.

pub async fn get_blobs_by_blober( &self, blober_blobs: BlobsByBlober, ) -> BloberClientResult<Vec<Vec<u8>>>

Fetches blobs for a given BlobsByBlober from the IndexerRpcClient.

pub async fn get_blobs_by_payer( &self, payer_blobs: BlobsByPayer, ) -> BloberClientResult<Vec<Vec<u8>>>

Fetches blobs for a given BlobsByPayer from the IndexerRpcClient.

pub async fn get_slot_proof( &self, slot: u64, namespace: &str, payer_pubkey: Option<Pubkey>, ) -> BloberClientResult<CompoundProof>

Fetches compound proof for a given slot from the IndexerRpcClient.

pub async fn get_blob_proof( &self, blob: Pubkey, ) -> BloberClientResult<Option<CompoundProof>>

Fetches compound proof for a given blob PDA Pubkey from the IndexerRpcClient.

pub async fn get_blob_messages( &self, slot: u64, namespace: &str, payer_pubkey: Option<Pubkey>, ) -> BloberClientResult<Vec<(Pubkey, VersionedMessage)>>

Fetches blob messages for a given slot Returns a tuple of (Pubkey, VersionedMessage) where the Pubkey is the address of the data_anchor_blober::state::blob::Blob account and the VersionedMessage is the message that included the data_anchor_blober::instruction::FinalizeBlob instruction.

Trait Implementations

impl Clone for BloberClient

fn clone(&self) -> BloberClient

Returns a duplicate of the value.

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

Performs copy-assignment from source.