return strbuf_printf(buf, GAUGE_FORMAT, v.fpcounter);
case METRIC_TYPE_UP_DOWN:
return strbuf_printf(buf, "%" PRId64, v.up_down);
- case METRIC_TYPE_UP_DOWN_COUNTER_FP:
- if (isnan(v.up_down_counter_fp)) {
+ case METRIC_TYPE_UP_DOWN_FP:
+ if (isnan(v.up_down_fp)) {
return strbuf_print(buf, "nan");
}
- return strbuf_printf(buf, GAUGE_FORMAT, v.up_down_counter_fp);
+ return strbuf_printf(buf, GAUGE_FORMAT, v.up_down_fp);
case METRIC_TYPE_UNTYPED:
break;
}
// (meaningfully) be summed up. Examples are filesystem space used and
// physical memory.
METRIC_TYPE_UP_DOWN = METRIC_ATTR_CUMULATIVE,
- // METRIC_TYPE_UP_DOWN_COUNTER_FP are absolute floating point metrics that can
+ // METRIC_TYPE_UP_DOWN_FP are absolute floating point metrics that can
// (meaningfully) be summed up.
- METRIC_TYPE_UP_DOWN_COUNTER_FP = METRIC_ATTR_DOUBLE | METRIC_ATTR_CUMULATIVE,
+ METRIC_TYPE_UP_DOWN_FP = METRIC_ATTR_DOUBLE | METRIC_ATTR_CUMULATIVE,
} metric_type_t;
#define METRIC_TYPE_TO_STRING(t) \
- (t == METRIC_TYPE_GAUGE) ? "gauge" \
- : (t == METRIC_TYPE_COUNTER) ? "counter" \
- : (t == METRIC_TYPE_FPCOUNTER) ? "fpcounter" \
- : (t == METRIC_TYPE_UP_DOWN) ? "up_down" \
- : (t == METRIC_TYPE_UP_DOWN_COUNTER_FP) ? "up_down_counter_fp" \
- : "unknown"
+ (t == METRIC_TYPE_GAUGE) ? "gauge" \
+ : (t == METRIC_TYPE_COUNTER) ? "counter" \
+ : (t == METRIC_TYPE_FPCOUNTER) ? "fpcounter" \
+ : (t == METRIC_TYPE_UP_DOWN) ? "up_down" \
+ : (t == METRIC_TYPE_UP_DOWN_FP) ? "up_down_fp" \
+ : "unknown"
#define IS_DOUBLE(t) ((t)&METRIC_ATTR_DOUBLE)
#define IS_MONOTONIC(t) ((t)&METRIC_ATTR_MONOTONIC)
counter_t counter;
fpcounter_t fpcounter;
up_down_counter_t up_down;
- up_down_counter_fp_t up_down_counter_fp;
+ up_down_counter_fp_t up_down_fp;
// For collectd 5 compatiblity. Treated the same as up_down.
derive_t derive;
};
return 0;
}
- case METRIC_TYPE_UP_DOWN_COUNTER_FP: {
- ce->values_gauge = (gauge_t)m->value.up_down_counter_fp;
+ case METRIC_TYPE_UP_DOWN_FP: {
+ ce->values_gauge = (gauge_t)m->value.up_down_fp;
return 0;
}
case METRIC_TYPE_UP_DOWN:
*ret = (gauge_t)m->value.up_down;
return 0;
- case METRIC_TYPE_UP_DOWN_COUNTER_FP:
- *ret = (gauge_t)m->value.up_down_counter_fp;
+ case METRIC_TYPE_UP_DOWN_FP:
+ *ret = (gauge_t)m->value.up_down_fp;
return 0;
case METRIC_TYPE_UNTYPED:
return EINVAL;
.want = 215,
},
{
- .name = "up_down_counter_fp",
- .first_value = (value_t){.up_down_counter_fp = 1.0},
- .second_value = (value_t){.up_down_counter_fp = 2.0},
+ .name = "up_down_fp",
+ .first_value = (value_t){.up_down_fp = 1.0},
+ .second_value = (value_t){.up_down_fp = 2.0},
.first_time = TIME_T_TO_CDTIME_T(100),
.second_time = TIME_T_TO_CDTIME_T(110),
- .type = METRIC_TYPE_UP_DOWN_COUNTER_FP,
+ .type = METRIC_TYPE_UP_DOWN_FP,
.want = 2.0,
},
{
- .name = "decreasing up_down_counter_fp",
- .first_value = (value_t){.up_down_counter_fp = 100.0},
- .second_value = (value_t){.up_down_counter_fp = 21.5},
+ .name = "decreasing up_down_fp",
+ .first_value = (value_t){.up_down_fp = 100.0},
+ .second_value = (value_t){.up_down_fp = 21.5},
.first_time = TIME_T_TO_CDTIME_T(100),
.second_time = TIME_T_TO_CDTIME_T(110),
- .type = METRIC_TYPE_UP_DOWN_COUNTER_FP,
+ .type = METRIC_TYPE_UP_DOWN_FP,
.want = 21.5,
},
};
} else if (strcasecmp("UP_DOWN_COUNTER", value) == 0) {
m->family->type = METRIC_TYPE_UP_DOWN;
} else if (strcasecmp("UP_DOWN_COUNTER_FP", value) == 0) {
- m->family->type = METRIC_TYPE_UP_DOWN_COUNTER_FP;
+ m->family->type = METRIC_TYPE_UP_DOWN_FP;
} else {
return CMD_ERROR;
}
case METRIC_TYPE_UP_DOWN:
strbuf_print(buf, " type=UP_DOWN_COUNTER");
break;
- case METRIC_TYPE_UP_DOWN_COUNTER_FP:
+ case METRIC_TYPE_UP_DOWN_FP:
strbuf_print(buf, " type=UP_DOWN_COUNTER_FP");
break;
case METRIC_TYPE_UNTYPED:
ret_value->up_down = (up_down_counter_t)strtoll(value, &endptr, 0);
break;
- case METRIC_TYPE_UP_DOWN_COUNTER_FP:
- ret_value->up_down_counter_fp =
- (up_down_counter_fp_t)strtod(value, &endptr);
+ case METRIC_TYPE_UP_DOWN_FP:
+ ret_value->up_down_fp = (up_down_counter_fp_t)strtod(value, &endptr);
break;
case METRIC_TYPE_UNTYPED:
state->last_value.up_down = (up_down_counter_t)floor(rate);
state->residual = rate - ((gauge_t)state->last_value.up_down);
break;
- case METRIC_TYPE_UP_DOWN_COUNTER_FP:
- state->last_value.up_down_counter_fp = (up_down_counter_fp_t)rate;
+ case METRIC_TYPE_UP_DOWN_FP:
+ state->last_value.up_down_fp = (up_down_counter_fp_t)rate;
state->residual = 0;
break;
case METRIC_TYPE_UNTYPED:
state->residual = delta_gauge - ((gauge_t)delta);
break;
}
- case METRIC_TYPE_UP_DOWN_COUNTER_FP: {
+ case METRIC_TYPE_UP_DOWN_FP: {
up_down_counter_fp_t delta = (up_down_counter_fp_t)delta_gauge;
- state->last_value.up_down_counter_fp += delta;
+ state->last_value.up_down_fp += delta;
state->residual = 0;
break;
}
*ret_rate = ((gauge_t)diff) / ((gauge_t)interval);
return 0;
}
- case METRIC_TYPE_UP_DOWN_COUNTER_FP: {
- up_down_counter_fp_t diff =
- value.up_down_counter_fp - state->last_value.up_down_counter_fp;
+ case METRIC_TYPE_UP_DOWN_FP: {
+ up_down_counter_fp_t diff = value.up_down_fp - state->last_value.up_down_fp;
*ret_rate = ((gauge_t)diff) / ((gauge_t)interval);
return 0;
}
EXPECT_EQ_UINT64(cases[i].want.up_down, got.up_down);
EXPECT_EQ_UINT64(cases[i].want.up_down, state.last_value.up_down);
break;
- case METRIC_TYPE_UP_DOWN_COUNTER_FP:
- EXPECT_EQ_DOUBLE(cases[i].want.up_down_counter_fp,
- got.up_down_counter_fp);
- EXPECT_EQ_UINT64(cases[i].want.up_down_counter_fp,
- state.last_value.up_down_counter_fp);
+ case METRIC_TYPE_UP_DOWN_FP:
+ EXPECT_EQ_DOUBLE(cases[i].want.up_down_fp, got.up_down_fp);
+ EXPECT_EQ_UINT64(cases[i].want.up_down_fp, state.last_value.up_down_fp);
break;
case METRIC_TYPE_UNTYPED:
LOG(false, "invalid metric type");
}
if ((m->family->type == METRIC_TYPE_GAUGE && isnan(m->value.gauge)) ||
- (m->family->type == METRIC_TYPE_UP_DOWN_COUNTER_FP &&
- isnan(m->value.up_down_counter_fp))) {
+ (m->family->type == METRIC_TYPE_UP_DOWN_FP &&
+ isnan(m->value.up_down_fp))) {
return EAGAIN;
}
return "FPCOUNTER";
case METRIC_TYPE_UP_DOWN:
return "UP_DOWN_COUNTER";
- case METRIC_TYPE_UP_DOWN_COUNTER_FP:
+ case METRIC_TYPE_UP_DOWN_FP:
return "UP_DOWN_COUNTER_FP";
case METRIC_TYPE_UNTYPED:
break;
CHECK(json_add_string(g, "asInt"));
CHECK(yajl_gen_integer(g, (long long int)m->value.up_down));
break;
- case METRIC_TYPE_UP_DOWN_COUNTER_FP:
+ case METRIC_TYPE_UP_DOWN_FP:
CHECK(json_add_string(g, "asDouble"));
- CHECK(yajl_gen_integer(g, m->value.up_down_counter_fp));
+ CHECK(yajl_gen_integer(g, m->value.up_down_fp));
break;
case METRIC_TYPE_UNTYPED:
ERROR("format_json_open_telemetry: Unexpected metric type: %d",
case METRIC_TYPE_COUNTER:
case METRIC_TYPE_FPCOUNTER:
case METRIC_TYPE_UP_DOWN:
- case METRIC_TYPE_UP_DOWN_COUNTER_FP:
+ case METRIC_TYPE_UP_DOWN_FP:
CHECK(json_add_string(g, "sum"));
CHECK(sum(g, fam));
break;
case METRIC_TYPE_UP_DOWN:
CHECK(yajl_gen_integer(g, (long long int)m->value.up_down));
return 0;
- case METRIC_TYPE_UP_DOWN_COUNTER_FP:
- CHECK(yajl_gen_double(g, m->value.up_down_counter_fp));
+ case METRIC_TYPE_UP_DOWN_FP:
+ CHECK(yajl_gen_double(g, m->value.up_down_fp));
return 0;
case METRIC_TYPE_UNTYPED:
break;
case METRIC_TYPE_FPCOUNTER:
dp->set_as_double(m->value.fpcounter);
return;
- case METRIC_TYPE_UP_DOWN_COUNTER_FP:
- dp->set_as_double(m->value.up_down_counter_fp);
+ case METRIC_TYPE_UP_DOWN_FP:
+ dp->set_as_double(m->value.up_down_fp);
return;
case METRIC_TYPE_UNTYPED:
// Fall through. This case signals the compiler that we're checking all
case METRIC_TYPE_COUNTER:
case METRIC_TYPE_FPCOUNTER:
case METRIC_TYPE_UP_DOWN:
- case METRIC_TYPE_UP_DOWN_COUNTER_FP:
+ case METRIC_TYPE_UP_DOWN_FP:
set_sum(m, fam);
return;
case METRIC_TYPE_UNTYPED:
}
break;
}
- case METRIC_TYPE_UP_DOWN_COUNTER_FP: {
+ case METRIC_TYPE_UP_DOWN_FP: {
int status = json_string(gen, "doubleValue") ||
- yajl_gen_double(gen, m->value.up_down_counter_fp);
+ yajl_gen_double(gen, m->value.up_down_fp);
if (status != 0) {
return status;
}
switch (m->family->type) {
case METRIC_TYPE_GAUGE:
case METRIC_TYPE_UP_DOWN:
- case METRIC_TYPE_UP_DOWN_COUNTER_FP:
+ case METRIC_TYPE_UP_DOWN_FP:
return json_string(gen, "GAUGE");
case METRIC_TYPE_COUNTER:
case METRIC_TYPE_FPCOUNTER:
switch (m->family->type) {
case METRIC_TYPE_GAUGE:
case METRIC_TYPE_FPCOUNTER:
- case METRIC_TYPE_UP_DOWN_COUNTER_FP:
+ case METRIC_TYPE_UP_DOWN_FP:
return json_string(gen, "DOUBLE");
case METRIC_TYPE_UP_DOWN:
case METRIC_TYPE_COUNTER:
break;
case METRIC_TYPE_UP_DOWN:
break;
- case METRIC_TYPE_UP_DOWN_COUNTER_FP:
- if (!isfinite(m->value.up_down_counter_fp)) {
+ case METRIC_TYPE_UP_DOWN_FP:
+ if (!isfinite(m->value.up_down_fp)) {
return EAGAIN;
}
break;
STRBUF_DESTROY(buf);
if (ds->ds[index].type == DS_TYPE_GAUGE) {
- fam->type = METRIC_TYPE_UP_DOWN_COUNTER_FP;
+ fam->type = METRIC_TYPE_UP_DOWN_FP;
} else {
fam->type = METRIC_TYPE_COUNTER;
}
switch (pfam->type) {
case METRIC_TYPE_GAUGE:
case METRIC_TYPE_UP_DOWN:
- case METRIC_TYPE_UP_DOWN_COUNTER_FP:
+ case METRIC_TYPE_UP_DOWN_FP:
type = "gauge";
break;
case METRIC_TYPE_COUNTER:
"\n",
},
{
- .name = "METRIC_TYPE_UP_DOWN_COUNTER_FP",
+ .name = "METRIC_TYPE_UP_DOWN_FP",
.pfam =
{
.name = "unit_test",
- .type = METRIC_TYPE_UP_DOWN_COUNTER_FP,
+ .type = METRIC_TYPE_UP_DOWN_FP,
.metrics =
(prometheus_metric_t[]){
- {.value.up_down_counter_fp = 42.0},
+ {.value.up_down_fp = 42.0},
},
.metrics_num = 1,
},