index 8041c0dfab9a4e1af2b5132d886528642ec5c27d..87c86a84f08d4f896ca50d79cc6c38d7879b8367 100644 (file)
}
for (i = 0; i < SDB_STATIC_ARRAY_LEN(hostnames); ++i) {
- if ((check = sdb_store_host(hostnames[i], sdb_gettime()))) {
+ if ((check = sdb_plugin_store_host(hostnames[i], sdb_gettime()))) {
sdb_log(SDB_LOG_ERR, "mock::plugin: Failed to store host: "
"status %d", check);
exit(1);
}
}
for (i = 0; i < SDB_STATIC_ARRAY_LEN(metrics); ++i) {
- if ((check = sdb_store_metric(metrics[i].hostname,
+ if ((check = sdb_plugin_store_metric(metrics[i].hostname,
metrics[i].metric, &metrics[i].store,
sdb_gettime()))) {
sdb_log(SDB_LOG_ERR, "mock::plugin: Failed to store metric: "
}
}
for (i = 0; i < SDB_STATIC_ARRAY_LEN(services); ++i) {
- if ((check = sdb_store_service(services[i].hostname,
+ if ((check = sdb_plugin_store_service(services[i].hostname,
services[i].service, sdb_gettime()))) {
sdb_log(SDB_LOG_ERR, "mock::plugin: Failed to store service: "
"status %d", check);
sdb_data_t datum = { SDB_TYPE_STRING, { .string = NULL } };
datum.data.string = strdup(attributes[i].value);
- if ((check = sdb_store_attribute(attributes[i].hostname,
+ if ((check = sdb_plugin_store_attribute(attributes[i].hostname,
attributes[i].name, &datum, sdb_gettime()))) {
sdb_log(SDB_LOG_ERR, "mock::plugin: Failed to store attribute: "
"status %d", check);
return 0;
} /* mock_collect */
-static sdb_timeseries_t *
-mock_fetch_ts(const char *id, sdb_timeseries_opts_t *opts,
- sdb_object_t *user_data)
-{
- sdb_timeseries_t *ts;
- const char *names[] = { "nameA", "nameB" };
- size_t i, j;
-
- if (*id != '/') {
- sdb_log(SDB_LOG_ERR, "mock::plugin: Invalid time-series %s", id);
- exit(1);
- }
-
- if (SDB_OBJ_WRAPPER(user_data)->data != MAGIC_DATA) {
- sdb_log(SDB_LOG_ERR, "mock::plugin: Invalid user data %p "
- "passed to collect", SDB_OBJ_WRAPPER(user_data)->data);
- exit(1);
- }
-
- ts = sdb_timeseries_create(SDB_STATIC_ARRAY_LEN(names), names, 10);
- if (! ts)
- return NULL;
-
- ts->start = opts->start;
- ts->end = opts->end;
-
- for (i = 0; i < 10; ++i) {
- for (j = 0; j < SDB_STATIC_ARRAY_LEN(names); ++j) {
- ts->data[j][i].timestamp = ts->start
- + i * (ts->end - ts->start) / 10;
- ts->data[j][i].value = (double)(i + j);
- }
- }
- return ts;
-} /* mock_fetch_ts */
-
static int
mock_config(oconfig_item_t *ci)
{
sdb_plugin_register_collector("main", mock_collect,
/* interval = */ NULL, user_data);
- sdb_plugin_register_ts_fetcher("mock", mock_fetch_ts, user_data);
-
sdb_object_deref(user_data);
return 0;
} /* mock_config */