Struct AggregatingStrategy

pub struct AggregatingStrategy<Db>
where
    Db: HoprDbTicketOperations + Send + Sync + Clone + Debug,
{ /* private fields */ }

Represents a strategy that starts aggregating tickets in a certain channel, once the number of acknowledged tickets in that channel goes above the given threshold. Optionally, the strategy can also redeem the aggregated ticket, if the aggregation was successful.

Implementations

impl<Db> AggregatingStrategy<Db>

where Db: HoprDbTicketOperations + Send + Sync + Clone + Debug,

pub fn new( cfg: AggregatingStrategyConfig, db: Db, ticket_aggregator: Arc<dyn TicketAggregatorTrait + Send + Sync + 'static>, ) -> Self

Trait Implementations

impl<Db> Debug for AggregatingStrategy<Db>

where Db: HoprDbTicketOperations + Send + Sync + Clone + Debug,

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

Formats the value using the given formatter.

impl<Db> Display for AggregatingStrategy<Db>

where Db: HoprDbTicketOperations + Send + Sync + Clone + Debug,

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

Formats the value using the given formatter.

impl<Db> SingularStrategy for AggregatingStrategy<Db>

where Db: HoprDbChannelOperations + HoprDbTicketOperations + Clone + Send + Sync + Debug + 'static,

fn on_tick<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Strategy event raised at period intervals (typically each 1 minute).

fn on_own_channel_changed<'life0, 'life1, 'async_trait>( &'life0 self, channel: &'life1 ChannelEntry, direction: ChannelDirection, change: ChannelChange, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Strategy event raised whenever the Indexer registers a change on node’s own channel.

fn on_acknowledged_winning_ticket<'life0, 'life1, 'async_trait>( &'life0 self, _ack: &'life1 AcknowledgedTicket, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Strategy event raised when a new winning acknowledged ticket is received in a channel