1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
|
#include "prometheus/family.h"
#include <gmock/gmock.h>
#include <gtest/gtest.h>
#include <memory>
#include "prometheus/client_metric.h"
#include "prometheus/counter.h"
#include "prometheus/detail/future_std.h"
#include "prometheus/histogram.h"
#include "prometheus/labels.h"
namespace prometheus {
namespace {
TEST(FamilyTest, labels) {
auto const_label = ClientMetric::Label{"component", "test"};
auto dynamic_label = ClientMetric::Label{"status", "200"};
Family<Counter> family{"total_requests",
"Counts all requests",
{{const_label.name, const_label.value}}};
family.Add({{dynamic_label.name, dynamic_label.value}});
auto collected = family.Collect();
ASSERT_GE(collected.size(), 1U);
ASSERT_GE(collected.at(0).metric.size(), 1U);
EXPECT_THAT(collected.at(0).metric.at(0).label,
::testing::ElementsAre(const_label, dynamic_label));
}
TEST(FamilyTest, reject_same_label_keys) {
auto labels = Labels{{"component", "test"}};
Family<Counter> family{"total_requests", "Counts all requests", labels};
EXPECT_ANY_THROW(family.Add(labels));
}
TEST(FamilyTest, counter_value) {
Family<Counter> family{"total_requests", "Counts all requests", {}};
auto& counter = family.Add({});
counter.Increment();
auto collected = family.Collect();
ASSERT_GE(collected.size(), 1U);
ASSERT_GE(collected[0].metric.size(), 1U);
EXPECT_EQ(1, collected[0].metric.at(0).counter.value);
}
TEST(FamilyTest, remove) {
Family<Counter> family{"total_requests", "Counts all requests", {}};
auto& counter1 = family.Add({{"name", "counter1"}});
family.Add({{"name", "counter2"}});
family.Remove(&counter1);
auto collected = family.Collect();
ASSERT_GE(collected.size(), 1U);
EXPECT_EQ(collected[0].metric.size(), 1U);
}
TEST(FamilyTest, removeUnknownMetricMustNotCrash) {
Family<Counter> family{"total_requests", "Counts all requests", {}};
family.Remove(nullptr);
}
TEST(FamilyTest, Histogram) {
Family<Histogram> family{"request_latency", "Latency Histogram", {}};
auto& histogram1 = family.Add({{"name", "histogram1"}},
Histogram::BucketBoundaries{0, 1, 2});
histogram1.Observe(0);
auto collected = family.Collect();
ASSERT_EQ(collected.size(), 1U);
ASSERT_GE(collected[0].metric.size(), 1U);
EXPECT_EQ(1U, collected[0].metric.at(0).histogram.sample_count);
}
TEST(FamilyTest, add_twice) {
Family<Counter> family{"total_requests", "Counts all requests", {}};
auto& counter = family.Add({{"name", "counter1"}});
auto& counter1 = family.Add({{"name", "counter1"}});
ASSERT_EQ(&counter, &counter1);
}
TEST(FamilyTest, throw_on_invalid_metric_name) {
auto create_family_with_invalid_name = []() {
return detail::make_unique<Family<Counter>>("", "empty name", Labels{});
};
EXPECT_ANY_THROW(create_family_with_invalid_name());
}
TEST(FamilyTest, throw_on_invalid_constant_label_name) {
auto create_family_with_invalid_labels = []() {
return detail::make_unique<Family<Counter>>(
"total_requests", "Counts all requests",
Labels{{"__inavlid", "counter1"}});
};
EXPECT_ANY_THROW(create_family_with_invalid_labels());
}
TEST(FamilyTest, should_throw_on_invalid_labels) {
Family<Counter> family{"total_requests", "Counts all requests", {}};
auto add_metric_with_invalid_label_name = [&family]() {
family.Add({{"__invalid", "counter1"}});
};
EXPECT_ANY_THROW(add_metric_with_invalid_label_name());
}
TEST(FamilyTest, should_not_collect_empty_metrics) {
Family<Counter> family{"total_requests", "Counts all requests", {}};
auto collected = family.Collect();
EXPECT_TRUE(collected.empty());
}
TEST(FamilyTest, query_family_if_metric_already_exists) {
Family<Counter> family{"total_rquests", "Counts all requests", {}};
family.Add({{"name", "counter1"}});
EXPECT_TRUE(family.Has({{"name", "counter1"}}));
EXPECT_FALSE(family.Has({{"name", "couner2"}}));
}
} // namespace
} // namespace prometheus
|
