durable_queue.h

Go to the documentation of this file.

 
#ifndef __CWIST_DURABLE_QUEUE_H__
#define __CWIST_DURABLE_QUEUE_H__
 
#include <cwist/sys/err/cwist_err.h>
#include <stddef.h>
#include <stdint.h>
 
#ifdef __cplusplus
extern "C" {
#endif
 
typedef struct cwist_redis cwist_redis_t;
typedef struct cwist_nats cwist_nats_t;
 
typedef struct cwist_job_queue cwist_job_queue_t;
 
typedef struct cwist_job cwist_job_t;
 
typedef struct cwist_job_queue_opts {
    const char *name;
    const char *consumer;
    uint64_t visibility_timeout_ms;
    uint32_t max_retries;
    uint64_t retry_delay_ms;
} cwist_job_queue_opts_t;
 
cwist_job_queue_t *cwist_job_queue_create_redis(cwist_redis_t *conn,
                                                const cwist_job_queue_opts_t *opts);
 
cwist_job_queue_t *cwist_job_queue_create_nats(cwist_nats_t *nats,
                                               const cwist_job_queue_opts_t *opts);
 
void cwist_job_queue_destroy(cwist_job_queue_t *q);
 
cwist_error_t cwist_job_queue_enqueue(cwist_job_queue_t *q, const void *payload, size_t payload_len,
                                      const char *type);
 
cwist_error_t cwist_job_queue_claim(cwist_job_queue_t *q, uint64_t timeout_ms, cwist_job_t **job);
 
cwist_error_t cwist_job_queue_ack(cwist_job_queue_t *q, cwist_job_t *job);
 
cwist_error_t cwist_job_queue_nack(cwist_job_queue_t *q, cwist_job_t *job);
 
void cwist_job_destroy(cwist_job_t *job);
 
const void *cwist_job_payload(const cwist_job_t *job, size_t *len);
 
const char *cwist_job_type(const cwist_job_t *job);
 
const char *cwist_job_id(const cwist_job_t *job);
 
uint32_t cwist_job_attempts(const cwist_job_t *job);
 
cwist_error_t cwist_job_queue_dead_count(cwist_job_queue_t *q, uint64_t *out_count);
 
#ifdef __cplusplus
}
#endif
 
#endif /* __CWIST_DURABLE_QUEUE_H__ */