Struct AggregatorUpkeepService

pub struct AggregatorUpkeepService { /* private fields */ }

Implementation of the upkeep service for the aggregator.

To ensure that connections are cleaned up properly, it creates new connections itself instead of relying on a connection pool or a shared connection.

Implementations

impl AggregatorUpkeepService

pub fn new( main_db_connection: Arc<SqliteConnection>, cardano_tx_connection_pool: Arc<SqliteConnectionPool>, event_store_connection: Arc<SqliteConnection>, signed_entity_type_lock: Arc<SignedEntityTypeLock>, pruning_tasks: Vec<Arc<dyn EpochPruningTask>>, logger: Logger, ) -> Self

Create a new instance of the aggregator upkeep service.

Trait Implementations

impl UpkeepService for AggregatorUpkeepService

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

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

Run the upkeep service.