Struct NatsWorker 

pub struct NatsWorker { /* private fields */ }

Consumes one model subject in the workers queue group.

Clones share one subscription. Replies require the incoming message’s reply subject; malformed JSON and missing reply subjects return errors.

Implementations

impl NatsWorker

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

Connects and subscribes to the prefix plus OPENAI_API_DEFAULT_MODEL.

Requires the model variable. URL/prefix defaults match NatsProducer::from_env_or_default; missing configuration, connection, and subscription errors are returned. No subscription flush is performed.

Trait Implementations

impl Clone for NatsWorker

fn clone(&self) -> NatsWorker

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for NatsWorker

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

Formats the value using the given formatter.

impl QueueWorker for NatsWorker

type Message = Message

Backend-specific reply metadata attached to each received task.

async fn receive_task(&self) -> Result<Option<WrappedTask<Self::Message>>>

Receives a task, or None when none is available or the stream ends.

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

Sends a response using the metadata from the corresponding task.