reth_transaction_pool::blobstore

Trait BlobStore

source 
pub trait BlobStore:
    Debug
    + Send
    + Sync
    + 'static {
    // Required methods
    fn insert(
        &self,
        tx: B256,
        data: BlobTransactionSidecar,
    ) -> Result<(), BlobStoreError>;
    fn insert_all(
        &self,
        txs: Vec<(B256, BlobTransactionSidecar)>,
    ) -> Result<(), BlobStoreError>;
    fn delete(&self, tx: B256) -> Result<(), BlobStoreError>;
    fn delete_all(&self, txs: Vec<B256>) -> Result<(), BlobStoreError>;
    fn cleanup(&self) -> BlobStoreCleanupStat;
    fn get(
        &self,
        tx: B256,
    ) -> Result<Option<BlobTransactionSidecar>, BlobStoreError>;
    fn contains(&self, tx: B256) -> Result<bool, BlobStoreError>;
    fn get_all(
        &self,
        txs: Vec<B256>,
    ) -> Result<Vec<(B256, BlobTransactionSidecar)>, BlobStoreError>;
    fn get_exact(
        &self,
        txs: Vec<B256>,
    ) -> Result<Vec<BlobTransactionSidecar>, BlobStoreError>;
    fn get_by_versioned_hashes(
        &self,
        versioned_hashes: &[B256],
    ) -> Result<Vec<Option<BlobAndProofV1>>, BlobStoreError>;
    fn data_size_hint(&self) -> Option<usize>;
    fn blobs_len(&self) -> usize;
}
Expand description

A blob store that can be used to store blob data of EIP4844 transactions.

This type is responsible for keeping track of blob data until it is no longer needed (after finalization).

Note: this is Clone because it is expected to be wrapped in an Arc.

Required Methods§

source

fn insert( &self, tx: B256, data: BlobTransactionSidecar, ) -> Result<(), BlobStoreError>

Inserts the blob sidecar into the store

source

fn insert_all( &self, txs: Vec<(B256, BlobTransactionSidecar)>, ) -> Result<(), BlobStoreError>

Inserts multiple blob sidecars into the store

source

fn delete(&self, tx: B256) -> Result<(), BlobStoreError>

Deletes the blob sidecar from the store

source

fn delete_all(&self, txs: Vec<B256>) -> Result<(), BlobStoreError>

Deletes multiple blob sidecars from the store

source

fn cleanup(&self) -> BlobStoreCleanupStat

A maintenance function that can be called periodically to clean up the blob store, returns the number of successfully deleted blobs and the number of failed deletions.

This is intended to be called in the background to clean up any old or unused data, in case the store uses deferred cleanup: DiskFileBlobStore

source

fn get( &self, tx: B256, ) -> Result<Option<BlobTransactionSidecar>, BlobStoreError>

Retrieves the decoded blob data for the given transaction hash.

source

fn contains(&self, tx: B256) -> Result<bool, BlobStoreError>

Checks if the given transaction hash is in the blob store.

source

fn get_all( &self, txs: Vec<B256>, ) -> Result<Vec<(B256, BlobTransactionSidecar)>, BlobStoreError>

Retrieves all decoded blob data for the given transaction hashes.

This only returns the blobs that were found in the store. If there’s no blob it will not be returned.

Note: this is not guaranteed to return the blobs in the same order as the input.

source

fn get_exact( &self, txs: Vec<B256>, ) -> Result<Vec<BlobTransactionSidecar>, BlobStoreError>

Returns the exact [BlobTransactionSidecar] for the given transaction hashes in the exact order they were requested.

Returns an error if any of the blobs are not found in the blob store.

source

fn get_by_versioned_hashes( &self, versioned_hashes: &[B256], ) -> Result<Vec<Option<BlobAndProofV1>>, BlobStoreError>

Return the [BlobTransactionSidecar]s for a list of blob versioned hashes.

source

fn data_size_hint(&self) -> Option<usize>

Data size of all transactions in the blob store.

source

fn blobs_len(&self) -> usize

How many blobs are in the blob store.

Implementors§