projects
/
collectd.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
removed separator between prefix and the rest of the key
[collectd.git]
/
src
/
write_redis.c
diff --git
a/src/write_redis.c
b/src/write_redis.c
index
22e30ab
..
dfa031c
100644
(file)
--- a/
src/write_redis.c
+++ b/
src/write_redis.c
@@
-40,6
+40,7
@@
struct wr_node_s
char *host;
int port;
struct timeval timeout;
char *host;
int port;
struct timeval timeout;
+ char *prefix;
redisContext *conn;
pthread_mutex_t lock;
redisContext *conn;
pthread_mutex_t lock;
@@
-67,7
+68,12
@@
static int wr_write (const data_set_t *ds, /* {{{ */
status = FORMAT_VL (ident, sizeof (ident), vl);
if (status != 0)
return (status);
status = FORMAT_VL (ident, sizeof (ident), vl);
if (status != 0)
return (status);
- ssnprintf (key, sizeof (key), "collectd/%s", ident);
+ if (node->prefix == NULL) {
+ ssnprintf (key, sizeof (key), "collectd/%s", ident);
+ }
+ else {
+ ssnprintf (key, sizeof (key), "%s/%s", node->prefix, ident);
+ }
ssnprintf (time, sizeof (time), "%.9f", CDTIME_T_TO_DOUBLE(vl->time));
memset (value, 0, sizeof (value));
ssnprintf (time, sizeof (time), "%.9f", CDTIME_T_TO_DOUBLE(vl->time));
memset (value, 0, sizeof (value));
@@
-176,6
+182,7
@@
static int wr_config_node (oconfig_item_t *ci) /* {{{ */
node->timeout.tv_sec = 0;
node->timeout.tv_usec = 1000;
node->conn = NULL;
node->timeout.tv_sec = 0;
node->timeout.tv_usec = 1000;
node->conn = NULL;
+ node->prefix = NULL;
pthread_mutex_init (&node->lock, /* attr = */ NULL);
status = cf_util_get_string_buffer (ci, node->name, sizeof (node->name));
pthread_mutex_init (&node->lock, /* attr = */ NULL);
status = cf_util_get_string_buffer (ci, node->name, sizeof (node->name));
@@
-204,6
+211,9
@@
static int wr_config_node (oconfig_item_t *ci) /* {{{ */
status = cf_util_get_int (child, &timeout);
if (status == 0) node->timeout.tv_usec = timeout;
}
status = cf_util_get_int (child, &timeout);
if (status == 0) node->timeout.tv_usec = timeout;
}
+ else if (strcasecmp ("Prefix", child->key) == 0) {
+ status = cf_util_get_string (child, &node->prefix);
+ }
else
WARNING ("write_redis plugin: Ignoring unknown config option \"%s\".",
child->key);
else
WARNING ("write_redis plugin: Ignoring unknown config option \"%s\".",
child->key);