Struct RingTelemetry 

pub struct RingTelemetry {
    pub control: ControlSnapshot,
    pub occupancy: RingOccupancy,
    pub slots: Vec<RingSlotSnapshot>,
    pub windows: Vec<WindowTelemetry>,
}

Combined host-visible telemetry for a megakernel run.

Fields

control: ControlSnapshot

Decoded control-buffer snapshot.

occupancy: RingOccupancy

Occupancy summary.

slots: Vec<RingSlotSnapshot>

All decoded slots.

windows: Vec<WindowTelemetry>

Decoded ticketed windows for any caller-specified window opcodes.

Implementations

impl RingTelemetry

pub fn sketch( &self, depth: usize, width: usize, ) -> Result<SketchTelemetry, PipelineError>

Build compact sketches from the decoded telemetry snapshot.

This is the host mirror of the telemetry shape a GPU-resident scheduler/fuzzer can maintain in control memory: hot opcodes, active work, tenant pressure, status pressure, and dispatch metrics all become bounded-size counters with deterministic replay semantics.

Errors

Returns PipelineError when sketch dimensions are invalid.

pub fn sketch_into( &self, depth: usize, width: usize, scratch: &mut SketchTelemetryScratch, ) -> Result<(), PipelineError>

Build compact sketches into caller-owned scratch.

Errors

Returns PipelineError when sketch dimensions are invalid.

impl RingTelemetry

pub fn decode(control_bytes: &[u8], ring_bytes: &[u8]) -> Self

Decode the ring and control buffers into one structured snapshot.

pub fn try_decode( control_bytes: &[u8], ring_bytes: &[u8], ) -> Result<Self, PipelineError>

Strictly decode ring and control bytes after validating ABI alignment.

Errors

Returns PipelineError when buffers are truncated or not aligned to the megakernel wire protocol.

pub fn decode_with_window_opcodes( control_bytes: &[u8], ring_bytes: &[u8], window_opcodes: &[u32], ) -> Self

Decode the ring and control buffers, additionally grouping any slots whose opcode is present in window_opcodes into ticketed route-window telemetry records.

pub fn decode_with_window_opcodes_into( control_bytes: &[u8], ring_bytes: &[u8], window_opcodes: &[u32], out: &mut Self, scratch: &mut TelemetryDecodeScratch, )

Decode the ring and control buffers into caller-owned telemetry and scratch storage.

pub fn try_decode_with_window_opcodes( control_bytes: &[u8], ring_bytes: &[u8], window_opcodes: &[u32], ) -> Result<Self, PipelineError>

Strictly decode ring/control bytes and group selected window opcodes.

Errors

Returns PipelineError when buffers are truncated or not aligned to the megakernel wire protocol.

pub fn try_decode_with_window_opcodes_into( control_bytes: &[u8], ring_bytes: &[u8], window_opcodes: &[u32], out: &mut Self, scratch: &mut TelemetryDecodeScratch, ) -> Result<(), PipelineError>

Strictly decode ring/control bytes into caller-owned telemetry and scratch storage.

Errors

Returns PipelineError when buffers are truncated or not aligned to the megakernel wire protocol.

pub fn active_slots_for_opcode(&self, opcode: u32) -> Vec<&RingSlotSnapshot>

Active slots matching a given opcode.

pub fn try_active_slots_for_opcode( &self, opcode: u32, ) -> Result<Vec<&RingSlotSnapshot>, PipelineError>

Active slots matching a given opcode with fallible output staging.

Errors

Returns PipelineError when output storage cannot be reserved.

pub fn active_slots_for_opcode_iter( &self, opcode: u32, ) -> impl Iterator<Item = &RingSlotSnapshot>

Active slots matching a given opcode as an iterator.

pub fn active_slots_for_opcode_into<'a>( &'a self, opcode: u32, out: &mut Vec<&'a RingSlotSnapshot>, )

Active slots matching a given opcode into caller-owned storage.

pub fn try_active_slots_for_opcode_into<'a>( &'a self, opcode: u32, out: &mut Vec<&'a RingSlotSnapshot>, ) -> Result<(), PipelineError>

Active slots matching a given opcode into caller-owned storage.

Errors

Returns PipelineError when output storage cannot be reserved.

pub fn active_windows(&self) -> Vec<&WindowTelemetry>

Unfinished ticketed windows.

pub fn try_active_windows(&self) -> Result<Vec<&WindowTelemetry>, PipelineError>

Unfinished ticketed windows with fallible output staging.

Errors

Returns PipelineError when output storage cannot be reserved.

pub fn active_windows_into<'a>(&'a self, out: &mut Vec<&'a WindowTelemetry>)

Unfinished ticketed windows into caller-owned storage.

pub fn try_active_windows_into<'a>( &'a self, out: &mut Vec<&'a WindowTelemetry>, ) -> Result<(), PipelineError>

Unfinished ticketed windows into caller-owned storage.

Errors

Returns PipelineError when output storage cannot be reserved.

pub fn priority_accounting(&self) -> PriorityRequeueAccounting

Summarize priority requeue/aging pressure visible in the ring snapshot.

pub fn runtime_counters(&self) -> MegakernelRuntimeCounters

Aggregate queue, idle, fairness, and drain counters into one cheap runtime snapshot for SRE dashboards and launch-policy feedback.

pub fn health_since( &self, previous: &RingTelemetry, ) -> MegakernelWatchdogSnapshot

Derive persistent-kernel health from two snapshots without polling the device or synchronizing with the GPU.

pub fn recommend_launch( &self, request: MegakernelLaunchRequest, ) -> Result<MegakernelLaunchRecommendation, BackendError>

Feed telemetry into the shared launch policy.

Errors

Returns a backend error when the supplied adapter limits are malformed.

Trait Implementations

impl Clone for RingTelemetry

fn clone(&self) -> RingTelemetry

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for RingTelemetry

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

Formats the value using the given formatter.

impl Default for RingTelemetry

fn default() -> RingTelemetry

Returns the “default value” for a type.

impl PartialEq for RingTelemetry

fn eq(&self, other: &RingTelemetry) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Eq for RingTelemetry

impl StructuralPartialEq for RingTelemetry