Struct rings_node::measure::PeriodicMeasure

pub struct PeriodicMeasure { /* private fields */ }

PeriodicMeasure is used to assess the reliability of peers by counting their behaviour. It currently count the number of sent and received messages in a given period (1 hour). The method Measure::incr should be called in the proper places.

Implementations

impl PeriodicMeasure

pub fn new(storage: PersistenceStorage) -> Self

Create a new PeriodicMeasure with the given storage.

Trait Implementations

impl BehaviourJudgement for PeriodicMeasure

fn good<'life0, 'async_trait>( &'life0 self, did: Did ) -> Pin<Box<dyn Future<Output = bool> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,

This asynchronous method should return a boolean indicating whether the node identified by did is behaving well.

impl<const T: i16> ConnectBehaviour<T> for PeriodicMeasure

fn good<'life0, 'async_trait>( &'life0 self, did: Did ) -> Pin<Box<dyn Future<Output = bool> + Send + 'async_trait, Global>>where 'life0: 'async_trait, Self: Sync + 'async_trait,

This asynchronous method returns a boolean indicating whether the node identified by did has a satisfactory connection behavior.

impl Debug for PeriodicMeasure

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

Formats the value using the given formatter.

impl Measure for PeriodicMeasure

fn incr<'life0, 'async_trait>( &'life0 self, did: Did, counter: MeasureCounter ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,

incr increments the counter of the given peer.

fn get_count<'life0, 'async_trait>( &'life0 self, did: Did, counter: MeasureCounter ) -> Pin<Box<dyn Future<Output = u64> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,

get_count returns the counter of a peer in the current or previous period.

impl<const T: i16> MessageRecvBehaviour<T> for PeriodicMeasure

fn good<'life0, 'async_trait>( &'life0 self, did: Did ) -> Pin<Box<dyn Future<Output = bool> + Send + 'async_trait, Global>>where 'life0: 'async_trait, Self: Sync + 'async_trait,

This asynchronous method returns a boolean indicating whether the node identified by did has a satisfactory message receiving behavior.

impl<const T: i16> MessageSendBehaviour<T> for PeriodicMeasure

fn good<'life0, 'async_trait>( &'life0 self, did: Did ) -> Pin<Box<dyn Future<Output = bool> + Send + 'async_trait, Global>>where 'life0: 'async_trait, Self: Sync + 'async_trait,

This asynchronous method returns a boolean indicating whether the node identified by did has a satisfactory message sending behavior.