Struct mithril_aggregator::services::MithrilSignedEntityService

pub struct MithrilSignedEntityService { /* private fields */ }

Mithril ArtifactBuilder Service

Implementations

impl MithrilSignedEntityService

pub fn new( signed_entity_storer: Arc<dyn SignedEntityStorer>, mithril_stake_distribution_artifact_builder: Arc<dyn ArtifactBuilder<Epoch, MithrilStakeDistribution>>, cardano_immutable_files_full_artifact_builder: Arc<dyn ArtifactBuilder<CardanoDbBeacon, Snapshot>>, cardano_transactions_artifact_builder: Arc<dyn ArtifactBuilder<BlockNumber, CardanoTransactionsSnapshot>>, signed_entity_type_lock: Arc<SignedEntityTypeLock>, cardano_stake_distribution_artifact_builder: Arc<dyn ArtifactBuilder<Epoch, CardanoStakeDistribution>>, logger: Logger, ) -> Self

MithrilSignedEntityService factory

Trait Implementations

impl Clone for MithrilSignedEntityService

fn clone(&self) -> MithrilSignedEntityService

Returns a copy of the value.

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

Performs copy-assignment from source.

impl SignedEntityService for MithrilSignedEntityService

fn create_artifact<'life0, 'life1, 'async_trait>( &'life0 self, signed_entity_type: SignedEntityType, certificate: &'life1 Certificate, ) -> Pin<Box<dyn Future<Output = StdResult<JoinHandle<StdResult<()>>>> + Send + 'async_trait>>

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

Create artifact for a signed entity type and a certificate

fn get_last_signed_snapshots<'life0, 'async_trait>( &'life0 self, total: usize, ) -> Pin<Box<dyn Future<Output = StdResult<Vec<SignedEntity<Snapshot>>>> + Send + 'async_trait>>

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

Return a list of signed snapshots order by creation date descending.

fn get_last_signed_mithril_stake_distributions<'life0, 'async_trait>( &'life0 self, total: usize, ) -> Pin<Box<dyn Future<Output = StdResult<Vec<SignedEntity<MithrilStakeDistribution>>>> + Send + 'async_trait>>

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

Return a list of signed Mithril stake distribution order by creation date descending.

fn get_last_cardano_transaction_snapshot<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = StdResult<Option<SignedEntity<CardanoTransactionsSnapshot>>>> + Send + 'async_trait>>

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

Return the last signed Cardano Transaction Snapshot.

fn get_signed_snapshot_by_id<'life0, 'life1, 'async_trait>( &'life0 self, signed_entity_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = StdResult<Option<SignedEntity<Snapshot>>>> + Send + 'async_trait>>

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

Return a signed snapshot

fn get_signed_mithril_stake_distribution_by_id<'life0, 'life1, 'async_trait>( &'life0 self, signed_entity_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = StdResult<Option<SignedEntity<MithrilStakeDistribution>>>> + Send + 'async_trait>>

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

Return a signed Mithril stake distribution

fn get_last_signed_cardano_stake_distributions<'life0, 'async_trait>( &'life0 self, total: usize, ) -> Pin<Box<dyn Future<Output = StdResult<Vec<SignedEntity<CardanoStakeDistribution>>>> + Send + 'async_trait>>

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

Return a list of signed Cardano stake distribution order by creation date descending.