Struct AssessmentTransport 

pub struct AssessmentTransport { /* private fields */ }

Real-time assessment mesh transport.

Connects the assessment layer’s MeshCoordinator with the K6 mesh networking stack. Holds an Arc reference to the coordinator so the same coordinator is shared with [AssessmentService].

The transport does not own any network connections itself. Instead it produces serialized MeshFrame bytes and accepts incoming bytes, delegating actual send/recv to the caller (typically the [MeshRuntime] or a dedicated assessment sync loop).

Implementations

impl AssessmentTransport

pub fn new(coordinator: Arc<MeshCoordinator>) -> Self

Create a new transport wrapping the given coordinator.

pub fn coordinator(&self) -> &MeshCoordinator

Return a reference to the inner coordinator.

pub fn coordinator_arc(&self) -> Arc<MeshCoordinator>

Shared coordinator handle (for status RPC / service wiring).

pub fn publish_report(&self, report: AssessmentReport)

Cache the latest local report (enables RequestReport responses + ticks).

pub fn latest_report(&self) -> Option<AssessmentReport>

Snapshot of the cached latest report.

pub fn build_gossip_frame( &self, report: &AssessmentReport, ) -> KernelResult<Vec<u8>>

Build a gossip frame from the latest assessment report.

Returns None if there is nothing to gossip (no report).

pub fn build_broadcast_frame( &self, report: &AssessmentReport, ) -> KernelResult<Vec<u8>>

Build a ReportAvailable broadcast frame.

pub fn build_diff_frame( &self, report: &AssessmentReport, diff: &AssessmentDiff, ) -> KernelResult<Vec<u8>>

Build a FindingDiff frame that carries only changed findings.

pub fn build_request_frame(&self) -> KernelResult<Vec<u8>>

Build a RequestReport frame addressed to a peer.

pub fn build_full_report_frame( &self, report: &AssessmentReport, ) -> KernelResult<Vec<u8>>

Build a FullReport response frame.

pub fn drain_pending(&self) -> Option<Vec<u8>>

Drain the pending broadcast (if any) from the coordinator and return it as encoded frame bytes ready for the wire.

pub fn try_extract_payload(data: &[u8]) -> KernelResult<Option<Vec<u8>>>

Try to decode an AssessmentSync payload from raw peer bytes.

Accepts either a full MeshFrame::encode buffer ([4-byte len][type][payload]) or a type-prefixed buffer ([type][payload] as produced after transport length stripping). Returns Ok(None) when the bytes are not an AssessmentSync frame (caller should fall through to IPC envelope handling).

pub fn try_handle_raw( &self, data: &[u8], ) -> KernelResult<Option<Option<Vec<u8>>>>

Handle raw peer bytes if they carry AssessmentSync; otherwise return Ok(None) so the mesh runtime can treat them as IPC.

On AssessmentSync, returns Ok(Some(response_bytes)) when a reply should be sent, or Ok(Some(empty)) is not used — Ok(Some(None)) isn’t valid. Convention: Ok(Some(opt_reply)) where outer Some means “this was assessment traffic”.

pub fn handle_incoming( &self, frame_payload: &[u8], ) -> KernelResult<Option<Vec<u8>>>

Handle an incoming AssessmentSync frame payload.

Decodes the envelope, feeds the inner message to the coordinator, and returns an optional response message (encoded as frame bytes) that should be sent back to the source peer. RequestReport is answered with a FullReport when a local report has been published.

pub fn gossip_tick( &self, latest_report: Option<&AssessmentReport>, ) -> Option<Vec<u8>>

Drive one gossip tick.

If the assessment service has a latest report, this builds a gossip message and returns it as encoded frame bytes for broadcast to all peers. The caller is responsible for sending the bytes to each connected peer.

Returns None if there is no report to gossip about.

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

Return a snapshot of all known peer assessment states.