wrapper/monitoring/prometheus: redesign, add subscriber and client wrappers

Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
This commit is contained in:
2020-04-17 02:45:40 +03:00
parent 0d429a180c
commit f6c0b6ca47
3 changed files with 324 additions and 107 deletions

View File

@@ -89,7 +89,7 @@ func TestPrometheusMetrics(t *testing.T) {
list, _ := prometheus.DefaultGatherer.Gather()
metric := findMetricByName(list, dto.MetricType_SUMMARY, "micro_upstream_latency_microseconds")
metric := findMetricByName(list, dto.MetricType_SUMMARY, "micro_handler_latency_microseconds")
if metric == nil || metric.Metric == nil || len(metric.Metric) == 0 {
t.Fatalf("no metrics returned")
@@ -117,7 +117,7 @@ func TestPrometheusMetrics(t *testing.T) {
assert.Equal(t, uint64(2), *metric.Metric[0].Summary.SampleCount)
assert.True(t, *metric.Metric[0].Summary.SampleSum > 0)
metric = findMetricByName(list, dto.MetricType_HISTOGRAM, "micro_request_duration_seconds")
metric = findMetricByName(list, dto.MetricType_HISTOGRAM, "micro_handler_request_duration_seconds")
for _, v := range metric.Metric[0].Label {
switch *v.Name {
@@ -141,7 +141,7 @@ func TestPrometheusMetrics(t *testing.T) {
assert.Equal(t, uint64(2), *metric.Metric[0].Histogram.SampleCount)
assert.True(t, *metric.Metric[0].Histogram.SampleSum > 0)
metric = findMetricByName(list, dto.MetricType_COUNTER, "micro_request_total")
metric = findMetricByName(list, dto.MetricType_COUNTER, "micro_handler_request_total")
for _, v := range metric.Metric[0].Label {
switch *v.Name {