Enum TelemetrySource 

pub enum TelemetrySource {
    Agent {
        agent_id: String,
    },
}

Which process is emitting an event.

Determines the NATS subject prefix. Currently only supports agent sources; the orchestrator defines its own source type in its crate.

Variants

Agent

Agent-side event. Subject: telemetry.agent.<agent_id>.<event>.

Fields

agent_id: String

Agent id as it appears in the JWT subject bind.

Implementations

impl TelemetrySource

pub fn agent(agent_id: impl Into<String>) -> Result<Self, String>

Construct an Agent source after validating that agent_id is a NATS-safe subject token. Returns Err if the id contains . / * / > / whitespace / control characters or is empty — using such an id would otherwise reshape the subject hierarchy and silently break the JWT-bound agent_id position contract.

Direct struct-literal construction (TelemetrySource::Agent { … }) is still permitted for tests and for callers that have already validated their input upstream (e.g. orchestrator JWT-issuance flow), but subject re-validates as defence-in-depth and refuses to emit malformed subjects.

pub fn subject( &self, kind: &str, custom_prefix: Option<&str>, ) -> Result<String, String>

Compute the NATS subject for a given event kind, optionally using a custom prefix (for testing / tenanted deployments).

The trailing path segment is the event’s snake_case kind (e.g. "task_accepted"). No event-payload fields appear in the subject, so there is no injection surface from the event data. The agent_id and any custom_prefix are validated against crate::nats_utils::validate_nats_name; an invalid token produces Err and the caller (typically TelemetryEmitter::emit) must drop the event rather than ship a malformed subject.

Trait Implementations

impl Clone for TelemetrySource

fn clone(&self) -> TelemetrySource

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for TelemetrySource

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

Formats the value using the given formatter.

impl Eq for TelemetrySource

impl PartialEq for TelemetrySource

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

Equality operator ==.

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

Inequality operator !=.

impl StructuralPartialEq for TelemetrySource