Skip to main content

TelemetryQueueExt

rill_core::queues::telemetry

Trait TelemetryQueueExt 

Source 
pub trait TelemetryQueueExt {
    // Required methods
    fn send_parameter(
        &self,
        port: PortId,
        parameter: ParameterId,
        value: f32,
    ) -> Result<(), QueueError>;
    fn send_signal(
        &self,
        node_id: NodeId,
        channel: usize,
        data: Vec<f32>,
    ) -> Result<(), QueueError>;
    fn send_signal_with_sample_rate(
        &self,
        node_id: NodeId,
        channel: usize,
        data: Vec<f32>,
        sample_rate: f32,
    ) -> Result<(), QueueError>;
    fn send_peak(&self, port: PortId, value: f32) -> Result<(), QueueError>;
    fn send_peak_with_hold(
        &self,
        port: PortId,
        value: f32,
        hold_time_ms: u32,
    ) -> Result<(), QueueError>;
    fn send_event(
        &self,
        source: &str,
        kind: &str,
        data: Vec<f32>,
    ) -> Result<(), QueueError>;
    fn send_event_with_description(
        &self,
        source: &str,
        kind: &str,
        data: Vec<f32>,
        description: &str,
    ) -> Result<(), QueueError>;
    fn send_violation(
        &self,
        component: &str,
        expected_ns: u64,
        actual_ns: u64,
        value: Option<f32>,
    ) -> Result<(), QueueError>;
}
Expand description

Convenience extension methods for TelemetryQueue.

Required Methods§

Source

fn send_parameter( &self, port: PortId, parameter: ParameterId, value: f32, ) -> Result<(), QueueError>

Send a parameter value telemetry event.

Source

fn send_signal( &self, node_id: NodeId, channel: usize, data: Vec<f32>, ) -> Result<(), QueueError>

Send a signal data telemetry event.

Source

fn send_signal_with_sample_rate( &self, node_id: NodeId, channel: usize, data: Vec<f32>, sample_rate: f32, ) -> Result<(), QueueError>

Send a signal data telemetry event with explicit sample rate.

Source

fn send_peak(&self, port: PortId, value: f32) -> Result<(), QueueError>

Send a peak value telemetry event.

Source

fn send_peak_with_hold( &self, port: PortId, value: f32, hold_time_ms: u32, ) -> Result<(), QueueError>

Send a peak value telemetry event with hold time.

Source

fn send_event( &self, source: &str, kind: &str, data: Vec<f32>, ) -> Result<(), QueueError>

Send an event telemetry event.

Source

fn send_event_with_description( &self, source: &str, kind: &str, data: Vec<f32>, description: &str, ) -> Result<(), QueueError>

Send an event telemetry event with description.

Source

fn send_violation( &self, component: &str, expected_ns: u64, actual_ns: u64, value: Option<f32>, ) -> Result<(), QueueError>

Send a micro-control violation telemetry event.

Implementors§