Struct SignedBeaconRepository

pub struct SignedBeaconRepository { /* private fields */ }

A SignedBeaconStore implementation using SQLite.

Implementations

impl SignedBeaconRepository

pub fn new( connection: Arc<SqliteConnection>, store_retention_limit: Option<u64>, ) -> Self

Create a new instance of the SignedBeaconRepository.

pub fn get_last(&self) -> StdResult<Option<SignedBeaconRecord>>

Get the last signed beacon.

pub fn prune_below_epoch(&self, epoch: Epoch) -> StdResult<()>

Prune all signed beacons that have an epoch below the given threshold.

Trait Implementations

impl EpochPruningTask for SignedBeaconRepository

fn pruned_data(&self) -> &'static str

Get the name of the data that will be pruned.

fn prune<'life0, 'async_trait>( &'life0 self, current_epoch: Epoch, ) -> Pin<Box<dyn Future<Output = StdResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Prune the datasource based on the given current epoch.

impl SignedBeaconStore for SignedBeaconRepository

fn filter_out_already_signed_entities<'life0, 'async_trait>( &'life0 self, entities: Vec<SignedEntityType>, ) -> Pin<Box<dyn Future<Output = StdResult<Vec<SignedEntityType>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Filter out already signed entities from a list of signed entities.

fn mark_beacon_as_signed<'life0, 'life1, 'async_trait>( &'life0 self, entity: &'life1 BeaconToSign, ) -> Pin<Box<dyn Future<Output = StdResult<()>> + Send + 'async_trait>>

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

Mark a beacon as signed.