Struct OnlineBlobProvider

pub struct OnlineBlobProvider<B: BeaconClient> {
    pub genesis_time: Option<u64>,
    pub slot_interval: Option<u64>,
    /* private fields */
}

An online implementation of the BlobProvider trait.

Fields

genesis_time: Option<u64>

Beacon Genesis time used for the time to slot conversion.

slot_interval: Option<u64>

Slot interval used for the time to slot conversion.

Implementations

impl<B: BeaconClient> OnlineBlobProvider<B>

pub const fn new( beacon_client: B, genesis_time: Option<u64>, slot_interval: Option<u64>, ) -> Self

Creates a new instance of the OnlineBlobProvider.

The genesis_time and slot_interval arguments are optional and the OnlineBlobProvider will attempt to load them dynamically at runtime if they are not provided.

pub async fn load_configs(&mut self) -> Result<(), BlobProviderError>

Loads the beacon genesis and config spec

pub async fn fetch_sidecars( &self, slot: u64, hashes: &[IndexedBlobHash], ) -> Result<Vec<BlobData>, BlobProviderError>

Fetches blob sidecars for the given slot and blob hashes.

pub const fn slot( genesis: u64, slot_time: u64, timestamp: u64, ) -> Result<u64, BlobProviderError>

Computes the slot for the given timestamp.

pub async fn fetch_filtered_sidecars( &self, block_ref: &BlockInfo, blob_hashes: &[IndexedBlobHash], ) -> Result<Vec<BlobTransactionSidecarItem>, BlobProviderError>

Fetches blob sidecars for the given block reference and blob hashes.

Trait Implementations

impl<B> BlobProvider for OnlineBlobProvider<B>

where B: BeaconClient + Send + Sync,

fn get_blobs<'life0, 'life1, 'life2, 'async_trait>( &'life0 mut self, block_ref: &'life1 BlockInfo, blob_hashes: &'life2 [IndexedBlobHash], ) -> Pin<Box<dyn Future<Output = Result<Vec<Box<Blob>>, Self::Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Fetches blob sidecars that were confirmed in the specified L1 block with the given indexed hashes. The blobs are validated for their index and hashes using the specified IndexedBlobHash.

type Error = BlobProviderError

The error type for the BlobProvider.

impl<B: Clone + BeaconClient> Clone for OnlineBlobProvider<B>

fn clone(&self) -> OnlineBlobProvider<B>

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<B: Debug + BeaconClient> Debug for OnlineBlobProvider<B>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.