mirror of
https://github.com/k3s-io/kubernetes.git
synced 2025-07-30 15:05:27 +00:00
Merge pull request #86723 from RainbowMango/pr_metrics_cleanup
Metrics stability framework cleanup
This commit is contained in:
commit
d9b5a40463
@ -188,6 +188,8 @@ func (c *selfCollector) Collect(ch chan<- prometheus.Metric) {
|
|||||||
// no-op vecs for convenience
|
// no-op vecs for convenience
|
||||||
var noopCounterVec = &prometheus.CounterVec{}
|
var noopCounterVec = &prometheus.CounterVec{}
|
||||||
var noopHistogramVec = &prometheus.HistogramVec{}
|
var noopHistogramVec = &prometheus.HistogramVec{}
|
||||||
|
|
||||||
|
// lint:ignore U1000 Keep it for future use
|
||||||
var noopSummaryVec = &prometheus.SummaryVec{}
|
var noopSummaryVec = &prometheus.SummaryVec{}
|
||||||
var noopGaugeVec = &prometheus.GaugeVec{}
|
var noopGaugeVec = &prometheus.GaugeVec{}
|
||||||
var noopObserverVec = &noopObserverVector{}
|
var noopObserverVec = &noopObserverVector{}
|
||||||
|
@ -31,7 +31,6 @@ import (
|
|||||||
|
|
||||||
var (
|
var (
|
||||||
v115 = semver.MustParse("1.15.0")
|
v115 = semver.MustParse("1.15.0")
|
||||||
v114 = semver.MustParse("1.14.0")
|
|
||||||
alphaCounter = NewCounter(
|
alphaCounter = NewCounter(
|
||||||
&CounterOpts{
|
&CounterOpts{
|
||||||
Namespace: "some_namespace",
|
Namespace: "some_namespace",
|
||||||
@ -100,7 +99,6 @@ func TestRegister(t *testing.T) {
|
|||||||
var tests = []struct {
|
var tests = []struct {
|
||||||
desc string
|
desc string
|
||||||
metrics []*Counter
|
metrics []*Counter
|
||||||
registryVersion *semver.Version
|
|
||||||
expectedErrors []error
|
expectedErrors []error
|
||||||
expectedIsCreatedValues []bool
|
expectedIsCreatedValues []bool
|
||||||
expectedIsDeprecated []bool
|
expectedIsDeprecated []bool
|
||||||
@ -109,7 +107,6 @@ func TestRegister(t *testing.T) {
|
|||||||
{
|
{
|
||||||
desc: "test alpha metric",
|
desc: "test alpha metric",
|
||||||
metrics: []*Counter{alphaCounter},
|
metrics: []*Counter{alphaCounter},
|
||||||
registryVersion: &v115,
|
|
||||||
expectedErrors: []error{nil},
|
expectedErrors: []error{nil},
|
||||||
expectedIsCreatedValues: []bool{true},
|
expectedIsCreatedValues: []bool{true},
|
||||||
expectedIsDeprecated: []bool{false},
|
expectedIsDeprecated: []bool{false},
|
||||||
@ -118,7 +115,6 @@ func TestRegister(t *testing.T) {
|
|||||||
{
|
{
|
||||||
desc: "test registering same metric multiple times",
|
desc: "test registering same metric multiple times",
|
||||||
metrics: []*Counter{alphaCounter, alphaCounter},
|
metrics: []*Counter{alphaCounter, alphaCounter},
|
||||||
registryVersion: &v115,
|
|
||||||
expectedErrors: []error{nil, prometheus.AlreadyRegisteredError{}},
|
expectedErrors: []error{nil, prometheus.AlreadyRegisteredError{}},
|
||||||
expectedIsCreatedValues: []bool{true, true},
|
expectedIsCreatedValues: []bool{true, true},
|
||||||
expectedIsDeprecated: []bool{false, false},
|
expectedIsDeprecated: []bool{false, false},
|
||||||
@ -127,7 +123,6 @@ func TestRegister(t *testing.T) {
|
|||||||
{
|
{
|
||||||
desc: "test alpha deprecated metric",
|
desc: "test alpha deprecated metric",
|
||||||
metrics: []*Counter{alphaDeprecatedCounter},
|
metrics: []*Counter{alphaDeprecatedCounter},
|
||||||
registryVersion: &v115,
|
|
||||||
expectedErrors: []error{nil},
|
expectedErrors: []error{nil},
|
||||||
expectedIsCreatedValues: []bool{true},
|
expectedIsCreatedValues: []bool{true},
|
||||||
expectedIsDeprecated: []bool{true},
|
expectedIsDeprecated: []bool{true},
|
||||||
@ -136,7 +131,6 @@ func TestRegister(t *testing.T) {
|
|||||||
{
|
{
|
||||||
desc: "test alpha hidden metric",
|
desc: "test alpha hidden metric",
|
||||||
metrics: []*Counter{alphaHiddenCounter},
|
metrics: []*Counter{alphaHiddenCounter},
|
||||||
registryVersion: &v115,
|
|
||||||
expectedErrors: []error{nil},
|
expectedErrors: []error{nil},
|
||||||
expectedIsCreatedValues: []bool{false},
|
expectedIsCreatedValues: []bool{false},
|
||||||
expectedIsDeprecated: []bool{true},
|
expectedIsDeprecated: []bool{true},
|
||||||
@ -153,7 +147,7 @@ func TestRegister(t *testing.T) {
|
|||||||
})
|
})
|
||||||
for i, m := range test.metrics {
|
for i, m := range test.metrics {
|
||||||
err := registry.Register(m)
|
err := registry.Register(m)
|
||||||
if err != test.expectedErrors[i] && err.Error() != test.expectedErrors[i].Error() {
|
if err != nil && err.Error() != test.expectedErrors[i].Error() {
|
||||||
t.Errorf("Got unexpected error %v, wanted %v", err, test.expectedErrors[i])
|
t.Errorf("Got unexpected error %v, wanted %v", err, test.expectedErrors[i])
|
||||||
}
|
}
|
||||||
if m.IsCreated() != test.expectedIsCreatedValues[i] {
|
if m.IsCreated() != test.expectedIsCreatedValues[i] {
|
||||||
@ -240,6 +234,7 @@ func TestShowHiddenMetric(t *testing.T) {
|
|||||||
registry.MustRegister(alphaHiddenCounter)
|
registry.MustRegister(alphaHiddenCounter)
|
||||||
|
|
||||||
ms, err := registry.Gather()
|
ms, err := registry.Gather()
|
||||||
|
assert.Nil(t, err, "Gather failed %v", err)
|
||||||
assert.Equalf(t, expectedMetricCount, len(ms), "Got %v metrics, Want: %v metrics", len(ms), expectedMetricCount)
|
assert.Equalf(t, expectedMetricCount, len(ms), "Got %v metrics, Want: %v metrics", len(ms), expectedMetricCount)
|
||||||
|
|
||||||
showHidden.Store(true)
|
showHidden.Store(true)
|
||||||
@ -257,9 +252,8 @@ func TestShowHiddenMetric(t *testing.T) {
|
|||||||
expectedMetricCount = 1
|
expectedMetricCount = 1
|
||||||
|
|
||||||
ms, err = registry.Gather()
|
ms, err = registry.Gather()
|
||||||
assert.Equalf(t, expectedMetricCount, len(ms), "Got %v metrics, Want: %v metrics", len(ms), expectedMetricCount)
|
|
||||||
assert.Nil(t, err, "Gather failed %v", err)
|
assert.Nil(t, err, "Gather failed %v", err)
|
||||||
|
assert.Equalf(t, expectedMetricCount, len(ms), "Got %v metrics, Want: %v metrics", len(ms), expectedMetricCount)
|
||||||
}
|
}
|
||||||
|
|
||||||
func TestValidateShowHiddenMetricsVersion(t *testing.T) {
|
func TestValidateShowHiddenMetricsVersion(t *testing.T) {
|
||||||
|
Loading…
Reference in New Issue
Block a user