user_data_t *ud)
{
wr_node_t *node = ud->data;
+ char ident[512];
char key[512];
char value[512];
size_t value_size;
int status;
int i;
- status = FORMAT_VL (value, sizeof (value), vl);
+ status = FORMAT_VL (ident, sizeof (ident), vl);
if (status != 0)
return (status);
- ssnprintf (key, sizeof (key), "collectd/%s", value);
+ ssnprintf (key, sizeof (key), "collectd/%s", ident);
memset (value, 0, sizeof (value));
value_size = sizeof (value);
} \
} while (0)
- APPEND ("%lu", (unsigned long) vl->time);
+ APPEND ("%lu:", (unsigned long) vl->time);
for (i = 0; i < ds->ds_num; i++)
{
if (ds->ds[i].type == DS_TYPE_COUNTER)
APPEND ("%llu", vl->values[i].counter);
else if (ds->ds[i].type == DS_TYPE_GAUGE)
- APPEND ("%g", vl->values[i].gauge);
+ APPEND (GAUGE_FORMAT, vl->values[i].gauge);
else if (ds->ds[i].type == DS_TYPE_DERIVE)
APPEND ("%"PRIi64, vl->values[i].derive);
else if (ds->ds[i].type == DS_TYPE_ABSOLUTE)
assert (node->conn != NULL);
status = credis_zadd (node->conn, key, (double) vl->time, value);
+ credis_sadd (node->conn, "collectd/values", ident);
+
pthread_mutex_unlock (&node->lock);
return (0);