* Enhance the given job argument with some functions * that can be called from the sandboxed job processor. * * Note, the `job` argument is a

* Wraps a raw client instance passed through the `connection` option in the * matching {@link IRedisClient} adapter, auto-detecting the underlying dr

<summary>Adds a flow atomically and returns the created job tree.</summary>

<summary>Adds a new job to the queue.</summary>

<summary> Atomically inserts a flow (tree) of jobs that may span multiple queues. Entries are ordered roots-first; a parent entry is inserted before i

<summary>Adds a single job, routing it to the correct initial state.</summary>

<summary> Registers (or overrides) a job scheduler and enqueues its next delayed iteration. Returns the created job id and its delay (ms). </summary>

<summary>Adds many independent jobs in a single efficient operation.</summary>

<summary>Appends a row to a job's log, optionally trimming. Returns the total count.</summary>

<summary>Changes the priority (and optionally lifo) of a waiting job.</summary>

<summary>Changes this job's priority (and optionally lifo) while waiting.</summary>

<summary>Removes jobs in a given state that are older than <paramref name="grace"/> ms.</summary>

<summary>Builds the connection client name (for discovery / observability).</summary>

<summary>Closes the producer and its connection (when owned).</summary>

<summary>Closes the backend and its owned connection(s).</summary>

<summary>Stops consuming events and closes the underlying connection.</summary>

<summary>Closes the worker, waiting for in-flight work to settle.</summary>

<summary> Closes the connection, disposing it only when owned. When <paramref name="allowCommandsToComplete"/> is <c>false</c>, any in-flight commands

<summary>Creates a Redis backend, establishing a connection from the options.</summary>

<summary>Establishes (or reuses) a connection from the given options.</summary>

<summary>Creates a backend bound to a fresh, unique queue.</summary>

<summary>Forcibly disconnects the backend's underlying connection(s).</summary>

<summary>Removes waiting (and optionally delayed) jobs from the queue.</summary>

Awaits a (cancelled) LISTEN wait so it fully unwinds, bounded so a stuck wait can never block shutdown. Exceptions/cancellation are expected.

<summary>Encodes an arbitrary supported value graph into MessagePack bytes.</summary>