Skip to main content

Module nats

Module nats 

Source
Expand description

JSON request/reply over Core NATS; requires std and a Tokio runtime. JSON request/reply on Core NATS, without JetStream persistence or task retries.

Subjects concatenate a prefix and model verbatim; no separator is inserted. Each task needs a reply subject. Ensure a worker subscription is active before publishing: constructors do not flush subscriptions as a readiness barrier.

Structsยง

NatsProducer
Publishes JSON tasks with a dedicated inbox for each response.
NatsWorker
Consumes one model subject in the workers queue group.