cwist_job_queue_opts Struct Reference

#include <durable_queue.h>

Public Attributes
const char *	name
const char *	consumer
uint64_t	visibility_timeout_ms
uint32_t	max_retries
uint64_t	retry_delay_ms

Detailed Description

Queue creation options.

Definition at line 45 of file durable_queue.h.

Member Data Documentation

consumer

const char* cwist_job_queue_opts::consumer

Worker identity within the consumer group. NULL picks a unique name (Redis: w<pid>-<n>; NATS: ephemeral durable consumer suffix).

Definition at line 51 of file durable_queue.h.

max_retries

uint32_t cwist_job_queue_opts::max_retries

Deliveries (including the first) before a job is dead-lettered. Must be >= 1. Default 5.

Definition at line 57 of file durable_queue.h.

name

const char* cwist_job_queue_opts::name

Queue name. Required. Used as the Redis key prefix (cwist:jq:<name>:*) and the JetStream stream name.

Definition at line 48 of file durable_queue.h.

retry_delay_ms

uint64_t cwist_job_queue_opts::retry_delay_ms

Delay before a nacked job becomes claimable again. Default 0 (immediate).

Definition at line 60 of file durable_queue.h.

visibility_timeout_ms

uint64_t cwist_job_queue_opts::visibility_timeout_ms

Time after which an unacknowledged job becomes claimable again. Default 30000 ms.

Definition at line 54 of file durable_queue.h.

---

The documentation for this struct was generated from the following file:

• include/cwist/sys/job/durable_queue.h