Struct TelemetrySinkSpec 

pub struct TelemetrySinkSpec {
    pub sink_id: TelemetrySinkId,
    pub sink_kind: TelemetrySinkKind,
    pub content_capture: TelemetryContentCaptureMode,
    pub queue_capacity: NonZeroUsize,
    pub terminal_reserve: NonZeroUsize,
    pub requires_idempotent_replay: bool,
}

Carries telemetry sink spec data across a host-port boundary. Constructing the value does not call the host; the port method that receives it documents any adapter, network, or storage effect.

Fields

sink_id: TelemetrySinkId

Stable sink id used for typed lineage, lookup, or dedupe.

sink_kind: TelemetrySinkKind

Kind discriminator for sink kind. Use it to route finite match arms without parsing display text.

content_capture: TelemetryContentCaptureMode

Content capture used by this record or request.

queue_capacity: NonZeroUsize

Queue capacity used by this record or request.

terminal_reserve: NonZeroUsize

Queue slots reserved for terminal frames. This keeps important terminal events available even when non-terminal frames overflow.

requires_idempotent_replay: bool

Boolean policy/capability flag for whether requires idempotent replay is enabled.

Implementations

impl TelemetrySinkSpec

pub fn safe_local_diagnostic(sink_id: impl Into<String>) -> Self

Builds the safe local diagnostic value. This is data construction and performs no I/O, journal append, event publication, or process work.

pub fn test(sink_id: impl Into<String>, queue_capacity: NonZeroUsize) -> Self

Builds the test value. This is data construction and performs no I/O, journal append, event publication, or process work.

pub fn with_content_capture(self, mode: TelemetryContentCaptureMode) -> Self

Returns this value with its content capture setting replaced. The method follows builder-style data construction and does not execute external work.

pub fn with_terminal_reserve(self, terminal_reserve: NonZeroUsize) -> Self

Returns this value with its terminal reserve setting replaced. The method follows builder-style data construction and does not execute external work.

Trait Implementations

impl Clone for TelemetrySinkSpec

fn clone(&self) -> TelemetrySinkSpec

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for TelemetrySinkSpec

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for TelemetrySinkSpec

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl PartialEq for TelemetrySinkSpec

fn eq(&self, other: &TelemetrySinkSpec) -> 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 Serialize for TelemetrySinkSpec

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl Eq for TelemetrySinkSpec

impl StructuralPartialEq for TelemetrySinkSpec