Struct MeshCoordinator 

pub struct MeshCoordinator { /* private fields */ }

Tracks peer assessment states and handles mesh protocol messages.

Lives inside AssessmentService (behind Option) and is only active when [mesh] enabled = true in the project config.

Implementations

impl MeshCoordinator

pub fn new(node_id: String, project_name: String) -> Self

Create a new coordinator for the given node and project.

pub fn handle_message( &self, msg: AssessmentMessage, ) -> Option<AssessmentMessage>

Process an incoming mesh message, optionally returning a response.

• Gossip updates peer state, no response.
• ReportAvailable updates peer state, no response.
• RequestReport returns nothing here (caller should check AssessmentService::get_latest() and build a FullReport).
• FullReport is handled by the caller (store the report).

pub fn build_gossip(&self, report: &AssessmentReport) -> AssessmentMessage

Build a gossip message from the latest assessment report.

pub fn build_broadcast(&self, report: &AssessmentReport) -> AssessmentMessage

Build a ReportAvailable broadcast from the latest report.

pub fn build_finding_diff( &self, report: &AssessmentReport, diff: &AssessmentDiff, ) -> AssessmentMessage

Build a FindingDiff push from an AssessmentDiff (changed findings only).

pub fn peer_states(&self) -> Vec<PeerAssessmentState>

Return a snapshot of all known peer assessment states.

pub fn update_peer(&self, state: PeerAssessmentState)

Store or update a peer’s assessment state.

pub fn set_pending_broadcast(&self, msg: AssessmentMessage)

Store a pending broadcast message for the daemon to pick up.

pub fn take_pending_broadcast(&self) -> Option<AssessmentMessage>

Take the pending broadcast (returns None if already consumed).

pub fn node_id(&self) -> &str

This node’s ID.

pub fn project_name(&self) -> &str

This node’s project name.