Struct PromiscuousStrategy

pub struct PromiscuousStrategy<Db, A>
where
    Db: HoprDbAllOperations + Clone,
    A: ChannelActions,
{ /* private fields */ }

This strategy opens outgoing channels to peers, which have quality above a given threshold. At the same time, it closes outgoing channels opened to peers whose quality dropped below this threshold.

Implementations

impl<Db, A> PromiscuousStrategy<Db, A>

where Db: HoprDbAllOperations + Clone, A: ChannelActions,

pub fn new( cfg: PromiscuousStrategyConfig, db: Db, hopr_chain_actions: A, ) -> Self

Trait Implementations

impl<Db, A> Debug for PromiscuousStrategy<Db, A>

where Db: HoprDbAllOperations + Clone, A: ChannelActions,

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

Formats the value using the given formatter.

impl<Db, A> Display for PromiscuousStrategy<Db, A>

where Db: HoprDbAllOperations + Clone, A: ChannelActions,

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

Formats the value using the given formatter.

impl<Db, A> SingularStrategy for PromiscuousStrategy<Db, A>

where Db: HoprDbAllOperations + Clone + Send + Sync, A: ChannelActions + Send + Sync,

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: Sync + '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: Sync + 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

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