The RRD service is a system-level service that aggregates quasi-continuous numerical data. For example, it can aggregate data like CPU load or disk usage. Unlike syslog, RRD aggregates the data: an RRD plugin reports data every 5 seconds but the service aggregates older data into statistical values (like minimum, maximum, and mean values.)
This library provides functions to register a plugin with the RRD service and to provide data sources. All data provided by the plugin is written periodically to a file from where it is read by the RRD daemon.
The Makefile builds the library and a simple test. The implementation
relies on a small JSON library that is included as a Git submodule. This
needs to be initialised:
make
make test
./rrdtest
The JSON library Parson is included as a copy of the source code.
The header file librrd.h contains the essential information to use the
library:
typedef ... rrd_value_t;
typedef ... RRD_SOURCE;
typedef ... RRD_PLUGIN;
RRD_PLUGIN *rrd_open(char *name, rrd_domain_t domain, char *path);
int rrd_close(RRD_PLUGIN * plugin);
int rrd_add_src(RRD_PLUGIN * plugin, RRD_SOURCE * source);
int rrd_del_src(RRD_PLUGIN * plugin, RRD_SOURCE * source);
int rrd_sample(RRD_PLUGIN * plugin, time_t (*t)(time_t*));
A plugin reports streams of data to the RRD service. Each such
stream is represented as an RRD_SOURCE value. An RRD_PLUGIN
registers itself with rrd_open and un-registers with rrd_close. Once
registered, data sources can be added and removed with rrd_add_src and
rrd_del_src.
Data is reported to the RRD service when calling rrd_sample. This
samples values from all data sources and writes the data to the path
provided to rrd_open. It is the client's responsibility to call
rrd_sample regularly at an interval of 5 seconds.
See rrdclient.c for a simple client that reads integers from standard
input as a data source and reports them to RRD. Here is how everything
is compiled and linked:
gcc -std=gnu99 -g -Wall -c -o librrd.o librrd.c
gcc -std=gnu99 -g -Wall -c -o parson/parson.o parson/parson.c
ar rc librrd.a librrd.o parson/parson.o
ranlib librrd.a
gcc -std=gnu99 -g -Wall -c -o rrdclient.o rrdclient.c
gcc -std=gnu99 -g -Wall -o rrdclient rrdclient.o librrd.a -lz
<<librrd.h>>=
#include <stdint.h>
#include "parson/parson.h"
<<constants>>
<<type definitions>>
<<function declarations>>
All strings are in UTF8 encoding. The library implements the following policy to manage memory: it does not free any memory that is hasn't itself allocated. This means, if the client passes dynamically allocated data into the library, it is the client's responsibility to de-allocate it.
A plugin opens a file for communication and periodically calls
rrd_sample to provide data. The type RRD_PLUGIN should be
considered private to the library.
<<type definitions>>=
/* rrd_domain_t */
typedef int32_t rrd_domain_t;
#define RRD_LOCAL_DOMAIN 0
#define RRD_INTER_DOMAIN 1
<<function declarations>>=
RRD_PLUGIN *rrd_open(char *name, rrd_domain_t domain, char *path);
int rrd_close(RRD_PLUGIN * plugin);
int rrd_sample(RRD_PLUGIN * plugin, time_t (*t)(time_t*));
The name of the plugin is descriptive, as whether it reports data
for a single machine (RRD_LOCAL_DOMAIN) or multiple
(RRD_INTER_DOMAIN). The second parameter of rrd_sample is deprecated
and will be ignored (and should be NULL).
When a plugin is opened, the file at path is being created and it is
removed when the plugin is closed.
A typical client has several data sources. A data source either reports integer or float values. Data sources can be added and removed dynamically.
<<type definitions>>=
/* rrd_scale_t */
typedef int32_t rrd_scale_t;
#define RRD_GAUGE 0
#define RRD_ABSOLUTE 1
#define RRD_DERIVE 2
/* rrd_owner_t */
typedef int32_t rrd_owner_t;
#define RRD_HOST 0
#define RRD_VM 1
#define RRD_SR 2
/* rrd_type_t */
typedef int32_t rrd_type_t;
#define RRD_FLOAT64 0
#define RRD_INT64 1
typedef union {
int64_t int64;
double float64;
} rrd_value_t;
typedef struct rrd_source {
char *name; /* name of the data source */
char *description; /* for user interface */
char *owner_uuid; /* UUID of the owner or NULL */
char *rrd_units; /* for user interface */
char *min; /* min <= sample() <= max */
char *max; /* min <= sample() <= max */
rrd_value_t(*sample) (void *userdata); /* reads
* value */
void *userdata; /* passed to sample() */
rrd_owner_t owner;
int32_t rrd_default; /* true: rrd daemon will archive */
rrd_scale_t scale; /* presentation of value */
rrd_type_t type; /* type of value */
} RRD_SOURCE;
typedef struct rrd_plugin RRD_PLUGIN;
<<function declarations>>=
int rrd_add_src(RRD_PLUGIN *plugin, RRD_SOURCE *source);
int rrd_del_src(RRD_PLUGIN *plugin, RRD_SOURCE *source);
An RRD_SOURCE has several descriptive fields for the value it is
reporting. It includes a function (pointer) sample that obtains the
value being reported. A value can be either a 64-bit integer or a 64-bit
floating point value -- discriminated by type. Part of an RRD_SOURCE
is a pointer userdata that is passed to sample(). This allows to
share a single sample function across several RRD_SOURCE values.
Some functions return an error code.
<<constants>>=
#define RRD_MAX_SOURCES 16
#define RRD_OK 0
#define RRD_TOO_MANY_SOURCES 1
#define RRD_NO_SOUCH_SOURCE 2
#define RRD_FILE_ERROR 3
#define RRD_ERROR 4
The library updates the file provided to rrd_open when rrd_sample is
called. The file format is combination of a binary header followed by a
JSON object containing meta data. As long as data sources are neither
added nor removed, the meta data doesn't change and only the binary data
is updated. When a data source is added or removed, the existing buffer
containing binary and meta data is invalidated, recomputed and gets
written out.
The design in constrained by the following behavior of the RRD daemon RRDD:
-
RRDD maps an RRD file into memory and does not re-read it if the file size changes. Therefore the library writes a static size that depends on
RRD_MAX_SOURCESand not on the actual number of data sources being in use. -
RRDD reads an RRD file and expects it have valid content. Hence, the library can't open the file and write it contents with a delay. Therefore the library writes an RRD file that indicated that initially there are no data sources and re-writes the file for each data source that is added. Checksums avoid other synchronisation problems.
The data layout is not defined by this library but by the existing daemon: https://github.com/xapi-project/rrd-transport/.
value bits format notes
header string (string length) * 8 string
"DATASOURCES"
data checksum 32 int32
binary-encoded crc32 of the concatenation of the encoded timestamp
and datasource values
metadata checksum 32 int32
binary-encoded crc32 of the metadata string (see below)
number of datasources 32 int32
only needed if the metadata has changed - otherwise RRDD can use a
cached value
timestamp 64 int64 Unix epoch
datasource values n * 64 int64
n is the number of datasources exported by the plugin
metadata length 32 int32
metadata (string length) * 8 string
All integers are in big endian.
00000000: 4441 5441 534f 5552 4345 53b2 49c2 820e DATASOURCES.I...
00000010: eade 5100 0000 0100 0000 0057 9210 4700 ..Q........W..G.
00000020: 0000 0057 9210 4700 0000 b27b 2264 6174 ...W..G....{"dat
00000030: 6173 6f75 7263 6573 223a 7b22 6375 7272 asources":{"curr
00000040: 656e 745f 7469 6d65 223a 7b22 6465 7363 ent_time":{"desc
00000050: 7269 7074 696f 6e22 3a22 5468 6520 6375 ription":"The cu
00000060: 7272 656e 7420 7469 6d65 222c 226f 776e rrent time","own
00000070: 6572 223a 2268 6f73 7422 2c22 7661 6c75 er":"host","valu
00000080: 655f 7479 7065 223a 2269 6e74 3634 222c e_type":"int64",
00000090: 2274 7970 6522 3a22 6761 7567 6522 2c22 "type":"gauge","
000000a0: 6465 6661 756c 7422 3a22 7472 7565 222c default":"true",
000000b0: 2275 6e69 7473 223a 2273 6563 6f6e 6473 "units":"seconds
000000c0: 222c 226d 696e 223a 222d 696e 6622 2c22 ","min":"-inf","
000000d0: 6d61 7822 3a22 696e 6622 7d7d 7d00 0000 max":"inf"}}}...
000000e0: 0000 0000 0000 0000 0000 0000 0000 0000 ................
{
"datasources": {
"current_time": {
"description": "The current time",
"owner": "host",
"value_type": "int64",
"type": "gauge",
"default": "true",
"units": "seconds",
"min": "-inf",
"max": "inf"
}
}
}
MIT License.