Struct Collector 

pub struct Collector {
    inner: CollectorInner,
}

The global telemetry collector.

This structure manages the collection and export of telemetry data. It maintains a unique execution ID, handles trace ID generation, and coordinates with the configured exporter.

The collector is typically accessed through the get_collector function rather than being constructed directly.

Fields

inner: CollectorInner

Implementations

impl Collector

fn new(process_id: ProcessId, exporter: &'static (dyn Export + Sync)) -> Self

pub(crate) fn process_id(&self) -> ProcessId

pub fn collect_external(&self, message: InstanceMessage<'_>)

Collects and exports an external telemetry message.

This method allows external systems to inject telemetry messages into the collector pipeline. The message will be exported using the configured exporter.

Examples

use core::num::NonZeroU64;
use veecle_telemetry::collector::get_collector;
use veecle_telemetry::protocol::{
    ThreadId,
    ProcessId,
    InstanceMessage,
    TelemetryMessage,
    TimeSyncMessage,
};

let collector = get_collector();
let message = InstanceMessage {
    thread: ThreadId::from_raw(ProcessId::from_raw(1), NonZeroU64::new(1).unwrap()),
    message: TelemetryMessage::TimeSync(TimeSyncMessage {
        local_timestamp: 0,
        since_epoch: 0,
    }),
};
collector.collect_external(message);

pub(crate) fn new_span(&self, span: SpanCreateMessage<'_>)

pub(crate) fn enter_span(&self, enter: SpanEnterMessage)

pub(crate) fn exit_span(&self, exit: SpanExitMessage)

pub(crate) fn close_span(&self, span: SpanCloseMessage)

pub(crate) fn span_event(&self, event: SpanAddEventMessage<'_>)

pub(crate) fn span_link(&self, link: SpanAddLinkMessage)

pub(crate) fn span_attribute(&self, attribute: SpanSetAttributeMessage<'_>)

pub(crate) fn log_message(&self, log: LogMessage<'_>)

fn tracing_message(&self, message: TracingMessage<'_>)

Trait Implementations

impl Debug for Collector

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

Formats the value using the given formatter.