1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
|
#ifndef XMAP_REDIS_H
#define XMAP_REDIS_H
#include <hiredis/hiredis.h>
#include <stdint.h>
#include <unistd.h>
#ifdef __cplusplus
extern "C" {
#endif
#define T_TCP 0
#define T_LOCAL 1
#define PMAP_REDIS_SUCCESS 0
#define PMAP_REDIS_EMPTY 1
#define PMAP_REDIS_ERROR -1
#define PMAP_REDIS_ERRLEN 1024
typedef struct redisconf {
int type;
char *path;
char *server;
uint16_t port;
char *list_name;
char error[PMAP_REDIS_ERRLEN];
} redisconf_t;
int redis_parse_connstr(char *connstr, redisconf_t *redis_conf);
int redis_existconf(redisContext *, const char *);
int redis_flush(redisContext *);
int redis_delconf(redisContext *, const char *);
int redis_setconf(redisContext *, const char *, char *);
int redis_getconf(redisContext *, const char *, char *, size_t);
long redis_get_sizeof_list(redisContext *, const char *);
long redis_get_sizeof_set(redisContext *, const char *);
int redis_lpush(redisContext *, char *, void *, int, size_t);
int redis_rpush(redisContext *, char *, void *, int, size_t);
int redis_lpull(redisContext *, char *, void *, int, size_t, int *);
int redis_spull(redisContext *, char *, void *, int, size_t, int *);
int redis_spush(redisContext *, char *, void *, int, size_t);
int redis_lpull_one(redisContext *rctx, char *queuename, void **buf,
size_t *len);
int redis_spull_one(redisContext *rctx, char *queuename, void **buf,
size_t *len);
int redis_lpush_one(redisContext *rctx, char *queuename, void *buf, size_t len);
int redis_rpush_one(redisContext *rctx, char *queuename, void *buf, size_t len);
int redis_spush_one(redisContext *rctx, char *queuename, void *buf, size_t len);
int redis_lpush_strings(redisContext *rctx, char *redisqueuename, char **buf,
int num);
int redis_rpush_strings(redisContext *rctx, char *redisqueuename, char **buf,
int num);
int redis_spush_strings(redisContext *rctx, char *redisqueuename, char **buf,
int num);
redisContext *redis_connect(char *connstr);
redisContext *redis_connect_from_conf(redisconf_t *rconf);
int redis_close(redisContext *rctx);
uint32_t redis_getconf_uint32_t(redisContext *, const char *);
int redis_setconf_uint32_t(redisContext *, const char *, uint32_t);
#ifdef __cplusplus
}
#endif
#endif // XMAP_REDIS_H
|
