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
|
// Copyright 2021 The Sigstore Authors.
//
// Licensed under the Apache License, Version 2.0 (the "License");
// you may not use this file except in compliance with the License.
// You may obtain a copy of the License at
//
// http://www.apache.org/licenses/LICENSE-2.0
//
// Unless required by applicable law or agreed to in writing, software
// distributed under the License is distributed on an "AS IS" BASIS,
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
// See the License for the specific language governing permissions and
// limitations under the License.
//
package main
import (
"flag"
"fmt"
"log"
"net/http"
dto "github.com/prometheus/client_model/go"
"github.com/prometheus/common/expfmt"
)
const (
latencyMetric = "fulcio_api_latency"
certMetric = "fulcio_new_certs"
)
func parseMF(url string) (map[string]*dto.MetricFamily, error) {
resp, err := http.Get(url) // nolint
if err != nil {
return nil, err
}
defer resp.Body.Close()
var parser expfmt.TextParser
return parser.TextToMetricFamilies(resp.Body)
}
func main() {
f := flag.String("url", "http://fulcio-server.fulcio-system.svc:2112/metrics", "set url to fetch metrics from")
flag.Parse()
mf, err := parseMF(*f)
if err != nil {
log.Fatalf("Failed to fetch/parse metrics: %v", err)
}
// Just grab the api_latency metric, make sure it's a histogram
// and just make sure there is at least one 200, and no errors there.
latency, ok := mf[latencyMetric]
if !ok || latency == nil {
log.Fatal("Did not get fulcio_api_latency metric")
}
if err := checkLatency(latency); err != nil {
log.Fatalf("fulcio_api_latency metric failed: %s", err)
}
// Then make sure the cert counter went up.
certCount, ok := mf[certMetric]
if !ok || certCount == nil {
log.Fatal("Did not get fulcio_new_certs metric")
}
if err := checkCertCount(certCount); err != nil {
log.Fatalf("fulcio_new_certs metric failed: %s", err)
}
}
// Make sure latency is a Histogram, and it has a POST with a 201.
func checkLatency(latency *dto.MetricFamily) error {
if *latency.Type != *dto.MetricType_HISTOGRAM.Enum() {
return fmt.Errorf("Wrong type, wanted %+v, got: %+v", dto.MetricType_HISTOGRAM.Enum(), latency.Type)
}
for _, metric := range latency.Metric {
var code string
var method string
for _, value := range metric.Label {
if *value.Name == "code" {
code = *value.Value
}
if *value.Name == "method" {
method = *value.Value
}
}
if code == "201" && method == "post" {
if *metric.Histogram.SampleCount != 1 {
return fmt.Errorf("Unexpected samplecount, wanted 1, got %d", *metric.Histogram.SampleCount)
}
return nil
}
}
return fmt.Errorf("Got multiple entries, or none for metric, wanted one, got: %+v", latency.Metric)
}
func checkCertCount(certCount *dto.MetricFamily) error {
if *certCount.Type != *dto.MetricType_COUNTER.Enum() {
return fmt.Errorf("Wrong type, wanted %+v, got: %+v", dto.MetricType_COUNTER.Enum(), certCount.Type)
}
if len(certCount.Metric) != 1 {
return fmt.Errorf("Got multiple entries, or none for metric, wanted one, got: %+v", certCount.Metric)
}
if *certCount.Metric[0].Counter.Value < 1 {
return fmt.Errorf("Got incorrect cert count, wanted one, got: %f", *certCount.Metric[0].Counter.Value)
}
return nil
}
|
