Module worker

Module worker 

Source

Structs§

HttpWorkerClient
InMemoryWorkerClient
In-memory client used in tests.
WorkerMessage
Individual message emitted by a worker.
WorkerRequest
Request payload for invoking a worker.
WorkerResponse
Response envelope returned by worker executions.
WorkerRoutingConfig
Routing configuration for the repo worker.

Enums§

WorkerClientError
WorkerTransport
Which transport to use for talking to the worker endpoint.

Constants§

DEFAULT_WORKER_ID
Canonical default worker identifier for the repo assistant.
DEFAULT_WORKER_NATS_SUBJECT
Default NATS subject used when no override is provided.
WORKER_ENVELOPE_VERSION
Worker envelope schema version.

Traits§

WorkerClient

Functions§

empty_worker_response_for
forward_to_worker
Sends a worker request via the provided client and maps the response back to outbound envelopes.
worker_messages_to_outbound
Converts a worker response into outbound envelopes targeting the same channel context.
worker_routes_from_env
Parse a simple worker route map from the WORKER_ROUTES env var.