Struct MultiStrategy

pub struct MultiStrategy { /* private fields */ }

Defines an execution chain of SingularStrategies. The MultiStrategy itself also implements the SingularStrategy trait, which makes it possible (along with different on_fail_continue policies) to construct various logical strategy chains.

Implementations

impl MultiStrategy

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

where Db: HoprDbAllOperations + Clone + Send + Sync + Debug + 'static,

Constructs new MultiStrategy. The strategy can contain another MultiStrategy if allow_recursive is set.

Trait Implementations

impl Debug for MultiStrategy

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

Formats the value using the given formatter.

impl Display for MultiStrategy

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

Formats the value using the given formatter.

impl SingularStrategy for MultiStrategy

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_acknowledged_winning_ticket<'life0, 'life1, 'async_trait>( &'life0 self, ack: &'life1 AcknowledgedTicket, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

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

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.