Struct Worker 

pub struct Worker<Q: QueueWorker, E: Executor> { /* private fields */ }

Connects a queue consumer to an executor, processing one task at a time.

Only NatsOpenaiWorker::from_env_or_default currently has a public constructor (with nats-queue enabled). Other queue/executor combinations require a caller-managed loop using their respective traits.

Implementations

impl Worker<NatsWorker, ExecutorAsyncOpenai>

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

Builds the NATS consumer and API executor from their environment settings.

Requires OPENAI_API_DEFAULT_MODEL and a reachable NATS server. See NatsWorker::from_env_or_default and ExecutorAsyncOpenai::from_env_or_default for defaults.

impl<Q: QueueWorker, E: Executor> Worker<Q, E>

pub async fn run(self) -> Result<()>

Processes tasks sequentially until the queue returns None or an error.

Queue and executor errors stop the loop immediately; execution errors are not converted into replies, and no application-level retry occurs. Responses with success == false are sent normally and do not stop it. A polling queue returning None ends the loop even if more work may arrive. There is no shutdown signal; callers must arrange cancellation themselves.

Trait Implementations

impl<Q: Clone + QueueWorker, E: Clone + Executor> Clone for Worker<Q, E>

fn clone(&self) -> Worker<Q, E>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<Q: Debug + QueueWorker, E: Debug + Executor> Debug for Worker<Q, E>

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

Formats the value using the given formatter.

impl<Q: QueueWorker, E: Executor> Executor for Worker<Q, E>

fn default_model(&self) -> &Arc<Option<String>>

Returns the fallback model used when a task does not specify one.

async fn execute(&self, task: Task) -> Result<Response>

Executes one task; Err indicates execution failed before a response.

impl<Q: QueueWorker, E: Executor> QueueWorker for Worker<Q, E>

type Message = <Q as QueueWorker>::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.