X-Git-Url: https://git.verplant.org/?a=blobdiff_plain;f=src%2Fwrite_redis.c;h=1bd9b20bedda7a9a9a3a2eba94d0ba7511296260;hb=34b102cd298ca53e8f0ab09a18d0b2ee82667d76;hp=22e30abb3833687f1a423810f19c1c4860d0efd6;hpb=d143bc65a6984281b7c757fd5ea6ef27af5681bb;p=collectd.git diff --git a/src/write_redis.c b/src/write_redis.c index 22e30abb..1bd9b20b 100644 --- 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 *prefix; 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); - ssnprintf (key, sizeof (key), "collectd/%s", ident); + if (node->prefix == NULL) { + ssnprintf (key, sizeof (key), "collectd/%s", ident); + } + else { + ssnprintf (key, sizeof (key), "%s/collectd/%s", node->prefix, ident); + } 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->prefix = NULL; 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; } + 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);