Struct PeerScore 

pub struct PeerScore {
    pub peer_id: String,
    pub topic_scores: HashMap<String, TopicScore>,
    pub behaviour_penalties: f64,
    pub app_specific_score: f64,
    pub last_decay: Instant,
}

Scoring state for a single peer.

Fields

peer_id: String

Identifier of the peer.

topic_scores: HashMap<String, TopicScore>

Per-topic scoring data.

behaviour_penalties: f64

Accumulated behaviour penalty sum.

app_specific_score: f64

Application-layer score modifier.

last_decay: Instant

Time of the last decay pass.

Implementations

impl PeerScore

pub fn new(peer_id: impl Into<String>) -> Self

Create a new PeerScore for the given peer.

pub fn composite_score(&self, params: &ScoreParameter) -> f64

Compute the composite score combining topic, delivery, and behaviour components, weighted by params.

composite = Σ(topic_score_i) * topic_weight
          + behaviour_penalties * behaviour_weight
          + app_specific_score * delivery_weight

pub fn apply_penalty(&mut self, p: BehaviourPenalty)

Apply a behaviour penalty to this peer.

pub fn record_first_delivery(&mut self, topic: &str)

Record that this peer was the first to deliver a message on topic.

pub fn record_mesh_delivery(&mut self, topic: &str)

Record a mesh message delivery for topic.

pub fn record_invalid_message(&mut self, topic: &str)

Record an invalid message on topic and increase the invalid_message_deliveries counter.

pub fn set_in_mesh(&mut self, topic: &str, in_mesh: bool)

Update the in-mesh flag for topic.

pub fn decay(&mut self, params: &ScoreParameter)

Decay all numeric score fields based on time elapsed since the last decay.

Decay factor: 0.9 ^ (elapsed_secs / decay_interval_secs)

Trait Implementations

impl Clone for PeerScore

fn clone(&self) -> PeerScore

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for PeerScore

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

Formats the value using the given formatter.