cwist_redis.h

Go to the documentation of this file.

 
#ifndef __CWIST_REDIS_H__
#define __CWIST_REDIS_H__
 
#include <cwist/sys/err/cwist_err.h>
#include <stddef.h>
 
#ifdef __cplusplus
extern "C" {
#endif
 
typedef struct cwist_redis cwist_redis_t;
 
typedef struct cwist_redis_pool cwist_redis_pool_t;
 
typedef void (*cwist_redis_msg_cb)(const char *channel, const char *message, void *ctx);
 
cwist_redis_t *cwist_redis_connect(const char *host, int port);
 
void cwist_redis_close(cwist_redis_t *r);
 
cwist_error_t cwist_redis_command(cwist_redis_t *r, const char *cmd, char **out);
 
cwist_error_t cwist_redis_command_argv(cwist_redis_t *r, size_t argc, const void *const *argv,
                                       const size_t *argv_lens, char **out, size_t *out_len);
 
cwist_error_t cwist_redis_auth(cwist_redis_t *r, const char *username, const char *password);
cwist_error_t cwist_redis_select(cwist_redis_t *r, unsigned int database);
 
typedef struct cwist_redis_reply {
    int type;
    char *str;
    size_t len;
    long long integer;
    struct cwist_redis_reply **element;
    size_t elements;
} cwist_redis_reply_t;
 
cwist_error_t cwist_redis_command_argv_reply(cwist_redis_t *r, size_t argc, const void *const *argv,
                                             const size_t *argv_lens, cwist_redis_reply_t **reply);
 
void cwist_redis_reply_free(cwist_redis_reply_t *reply);
 
cwist_error_t cwist_redis_get(cwist_redis_t *r, const char *key, char **out_value);
cwist_error_t cwist_redis_set(cwist_redis_t *r, const char *key, const char *value);
cwist_error_t cwist_redis_setex(cwist_redis_t *r, const char *key, const char *value, int seconds);
cwist_error_t cwist_redis_del(cwist_redis_t *r, const char *key);
cwist_error_t cwist_redis_expire(cwist_redis_t *r, const char *key, int seconds);
cwist_error_t cwist_redis_publish(cwist_redis_t *r, const char *channel, const char *message);
cwist_error_t cwist_redis_subscribe(cwist_redis_t *r, const char **channels, cwist_redis_msg_cb cb,
                                    void *ctx);
 
cwist_redis_pool_t *cwist_redis_pool_create(const char *host, int port, size_t max_conns);
 
void cwist_redis_pool_destroy(cwist_redis_pool_t *pool);
 
cwist_error_t cwist_redis_pool_get(cwist_redis_pool_t *pool, const char *key, char **out_value);
cwist_error_t cwist_redis_pool_set(cwist_redis_pool_t *pool, const char *key, const char *value);
cwist_error_t cwist_redis_pool_setex(cwist_redis_pool_t *pool, const char *key, const char *value,
                                     int seconds);
cwist_error_t cwist_redis_pool_del(cwist_redis_pool_t *pool, const char *key);
cwist_error_t cwist_redis_pool_publish(cwist_redis_pool_t *pool, const char *channel,
                                       const char *message);
cwist_error_t cwist_redis_pool_command_argv(cwist_redis_pool_t *pool, size_t argc,
                                            const void *const *argv, const size_t *argv_lens,
                                            char **out, size_t *out_len);
cwist_error_t cwist_redis_pool_command_argv_reply_timeout(cwist_redis_pool_t *pool, size_t argc,
                                                          const void *const *argv,
                                                          const size_t *argv_lens,
                                                          unsigned timeout_ms,
                                                          cwist_redis_reply_t **reply);
 
#ifdef __cplusplus
}
#endif
 
#endif /* __CWIST_REDIS_H__ */