Struct NatsSubjectChannel 

pub struct NatsSubjectChannel {
    pub subject: String,
    pub stream: String,
    pub url: Option<String>,
}

NATS JetStream channel — guaranteed-delivery publish.

Fields

subject: String

Subject to publish to. May contain {{run_id}} template substitution — the worker substitutes the resolved run id at publish time.

stream: String

JetStream stream the subject belongs to. The stream itself is declared by the consumer chart (e.g. tatara-pool-reconciler) via the pleme-nats broker-only design.

url: Option<String>

Optional NATS URL. Defaults to nats://nats.observability.svc.cluster.local:4222.

Implementations

impl NatsSubjectChannel

pub fn resolved_url(&self) -> &str

Resolve the NATS URL, falling back to the in-cluster default.

pub fn publish(subject: impl Into<String>, stream: impl Into<String>) -> Self

Compose a NatsSubjectChannel pinned to the in-cluster default NATS URL (DEFAULT_NATS_URL, stamped as url: None so Self::resolved_url resolves the same URL on read) and the given subject + stream — the ONE substrate primitive owning the 3-slot NatsSubjectChannel { subject, stream, url: None } fixture literal every consumer restated by hand pre-lift.

Pre-lift the same 3-slot chain (subject: <s>.into(), stream: <s>.into(), url: None) was hand-authored at SIX workspace-wide sites past the ★★ PRIME-DIRECTIVE ≥ 2 duplication threshold, EVERY one of them the “default-URL, subject-and-stream-only” shape (no site in the workspace stamps a non-None url on a NatsSubjectChannel literal):

• tatara-process::export — two sites: the vector_channel_resolves_nats_subject round-trip fixture plus the single_slot_channel closed-set ambiguity probe.
• tatara-process::tagged_union — one site: the single_slot_vector_channel_probe closed-set probe (the sibling of the single_slot_channel fixture in tatara-process::export).
• tatara-reconciler::render — one site: the spec_receipts_attested fixture the ephemeral-export-Job renderer’s tests seed.
• tatara-export-worker::lib — two sites: the subject_substitutes_run_id_template template-substitution fixture plus the subject_passthrough_when_no_template passthrough fixture.

Post-lift every callsite reads NatsSubjectChannel::publish(<subject>, <stream>) and the three-slot struct’s url slot stays owned by the ONE substrate site. The impl Into<String> bound on both positional args accepts every pre-lift caller shape verbatim — &'static str literals ("S", "EPHEMERAL_RECEIPTS", "pleme.pleme-dev.ephemeral.{{run_id}}.receipt"), owned String values, and .into()-terminated chains alike — without a per-site coercion.

A future addition (a default-URL override for a per-fleet NATS endpoint, a per-fleet subject prefix normalization, a stream clamp against a shinryu-registered stream catalog, or an authenticated NATS URL seed pulled from a config surface) lands at THIS ONE substrate primitive and every downstream consumer inherits the upgrade mechanically — no per-site edit at any of the six listed callers or at future test fixtures.

Theory anchor: THEORY.md §VI.1 (generation over composition — the NatsSubjectChannel { subject, stream, url: None } fixture literal recurred at six hand-authored sites past the ★★ PRIME-DIRECTIVE ≥ 2 duplication trigger, and is lifted to ONE owner here). THEORY.md §II.1 invariant 5 (composition preserves proofs — a regression that drifted the default-URL sentinel from None to a hardcoded string, or reordered the three struct slots, surfaces at the publish_composes_byte_identical_to_pre_lift_literal_across_every_subject_stream_pair pin below rather than as silent skew at every downstream fixture).

Trait Implementations

impl Clone for NatsSubjectChannel

fn clone(&self) -> NatsSubjectChannel

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for NatsSubjectChannel

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for NatsSubjectChannel

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl JsonSchema for NatsSubjectChannel

fn schema_name() -> String

The name of the generated JSON Schema.

fn schema_id() -> Cow<'static, str>

Returns a string that uniquely identifies the schema produced by this type.

fn json_schema(generator: &mut SchemaGenerator) -> Schema

Generates a JSON Schema for this type.

fn is_referenceable() -> bool

Whether JSON Schemas generated for this type should be re-used where possible using the $ref keyword.

impl Serialize for NatsSubjectChannel

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

where __S: Serializer,

Serialize this value into the given Serde serializer.