Struct NoopEventSink 

pub struct NoopEventSink;

A no-op implementation of EventSink for testing and benchmarking.

All methods are empty. Returns ObservabilityLevel::Off.

Examples

use torvyn_types::{NoopEventSink, EventSink, FlowId, ComponentId, ObservabilityLevel};
use torvyn_types::InvocationStatus;

let sink = NoopEventSink;
sink.record_invocation(FlowId::new(1), ComponentId::new(1), 0, 100, InvocationStatus::Ok);
assert_eq!(sink.level(), ObservabilityLevel::Off);

Trait Implementations

impl Clone for NoopEventSink

fn clone(&self) -> NoopEventSink

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl EventSink for NoopEventSink

fn record_invocation( &self, _flow_id: FlowId, _component_id: ComponentId, _start_ns: u64, _end_ns: u64, _status: InvocationStatus, )

Record a component invocation completion.

fn record_element_transfer( &self, _flow_id: FlowId, _stream_id: StreamId, _element_sequence: u64, _queue_depth_after: u32, )

Record a stream element transfer between components.

fn record_backpressure( &self, _flow_id: FlowId, _stream_id: StreamId, _activated: bool, _queue_depth: u32, _timestamp_ns: u64, )

Record a backpressure state change.

fn record_copy( &self, _flow_id: FlowId, _resource_id: ResourceId, _from_component: ComponentId, _to_component: ComponentId, _copy_bytes: u64, _reason: CopyReason, )

Record a resource copy operation.

fn level(&self) -> ObservabilityLevel

Returns the current observability level.

impl Copy for NoopEventSink