Struct NatsProducer 

pub struct NatsProducer { /* private fields */ }

Publishes JSON tasks with a dedicated inbox for each response.

Explicit task models override the configured default. Sending fails if neither exists. Receiving waits for the first inbox message and decodes it as a Response; no built-in response timeout or NATS-status handling is provided. Use Task::send_and_wait with a timeout to bound the reply wait.

Implementations

impl NatsProducer

pub async fn from_env_or_default() -> Result<Self>

Connects using OPENAI_API_NATS_URL (default nats://localhost:4222).

Snapshots OPENAI_API_NATS_PREFIX (default openai-api-queue/) and the optional OPENAI_API_DEFAULT_MODEL. Connection errors are returned.

Trait Implementations

impl Clone for NatsProducer

fn clone(&self) -> NatsProducer

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for NatsProducer

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

Formats the value using the given formatter.

impl QueueProducer for NatsProducer

type Message = Subscriber

Backend-specific handle used to correlate a submitted task’s response.

async fn send_task(&self, task: Task) -> Result<Self::Message>

Submits a task and returns its response handle, not its execution result.

async fn receive_response( &self, message: Self::Message, ) -> Result<Option<Response>>

Consumes a handle to retrieve a response.