mirror of
https://github.com/kubernetes-sigs/prometheus-adapter.git
synced 2026-04-06 17:57:51 +00:00
109 lines
4.6 KiB
Go
109 lines
4.6 KiB
Go
/*
|
|
Copyright 2017 The Kubernetes 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 provider
|
|
|
|
import (
|
|
"time"
|
|
|
|
"github.com/kubernetes-incubator/custom-metrics-apiserver/pkg/provider"
|
|
. "github.com/onsi/ginkgo"
|
|
. "github.com/onsi/gomega"
|
|
"k8s.io/apimachinery/pkg/runtime/schema"
|
|
fakedyn "k8s.io/client-go/dynamic/fake"
|
|
|
|
config "github.com/directxman12/k8s-prometheus-adapter/cmd/config-gen/utils"
|
|
prom "github.com/directxman12/k8s-prometheus-adapter/pkg/client"
|
|
fakeprom "github.com/directxman12/k8s-prometheus-adapter/pkg/client/fake"
|
|
pmodel "github.com/prometheus/common/model"
|
|
)
|
|
|
|
const fakeProviderUpdateInterval = 2 * time.Second
|
|
|
|
func setupPrometheusProvider() (provider.CustomMetricsProvider, *fakeprom.FakePrometheusClient) {
|
|
fakeProm := &fakeprom.FakePrometheusClient{}
|
|
fakeKubeClient := &fakedyn.FakeDynamicClient{}
|
|
|
|
cfg := config.DefaultConfig(1*time.Minute, "")
|
|
namers, err := NamersFromConfig(cfg, restMapper())
|
|
Expect(err).NotTo(HaveOccurred())
|
|
|
|
prov, _ := NewPrometheusProvider(restMapper(), fakeKubeClient, fakeProm, namers, fakeProviderUpdateInterval)
|
|
|
|
containerSel := prom.MatchSeries("", prom.NameMatches("^container_.*"), prom.LabelNeq("container_name", "POD"), prom.LabelNeq("namespace", ""), prom.LabelNeq("pod_name", ""))
|
|
namespacedSel := prom.MatchSeries("", prom.LabelNeq("namespace", ""), prom.NameNotMatches("^container_.*"))
|
|
fakeProm.SeriesResults = map[prom.Selector][]prom.Series{
|
|
containerSel: {
|
|
{
|
|
Name: "container_some_usage",
|
|
Labels: pmodel.LabelSet{"pod_name": "somepod", "namespace": "somens", "container_name": "somecont"},
|
|
},
|
|
},
|
|
namespacedSel: {
|
|
{
|
|
Name: "ingress_hits_total",
|
|
Labels: pmodel.LabelSet{"ingress": "someingress", "service": "somesvc", "pod": "backend1", "namespace": "somens"},
|
|
},
|
|
{
|
|
Name: "ingress_hits_total",
|
|
Labels: pmodel.LabelSet{"ingress": "someingress", "service": "somesvc", "pod": "backend2", "namespace": "somens"},
|
|
},
|
|
{
|
|
Name: "service_proxy_packets",
|
|
Labels: pmodel.LabelSet{"service": "somesvc", "namespace": "somens"},
|
|
},
|
|
{
|
|
Name: "work_queue_wait_seconds_total",
|
|
Labels: pmodel.LabelSet{"deployment": "somedep", "namespace": "somens"},
|
|
},
|
|
},
|
|
}
|
|
|
|
return prov, fakeProm
|
|
}
|
|
|
|
var _ = Describe("Custom Metrics Provider", func() {
|
|
It("should be able to list all metrics", func() {
|
|
By("setting up the provider")
|
|
prov, fakeProm := setupPrometheusProvider()
|
|
|
|
By("ensuring that no metrics are present before we start listing")
|
|
Expect(prov.ListAllMetrics()).To(BeEmpty())
|
|
|
|
By("setting the acceptible interval to now until the next update, with a bit of wiggle room")
|
|
startTime := pmodel.Now().Add(-1*fakeProviderUpdateInterval - fakeProviderUpdateInterval/10)
|
|
fakeProm.AcceptableInterval = pmodel.Interval{Start: startTime, End: 0}
|
|
|
|
By("updating the list of available metrics")
|
|
// don't call RunUntil to avoid timing issue
|
|
lister := prov.(*prometheusProvider).SeriesRegistry.(*cachingMetricsLister)
|
|
Expect(lister.updateMetrics()).To(Succeed())
|
|
|
|
By("listing all metrics, and checking that they contain the expected results")
|
|
Expect(prov.ListAllMetrics()).To(ConsistOf(
|
|
provider.CustomMetricInfo{schema.GroupResource{Resource: "services"}, true, "ingress_hits"},
|
|
provider.CustomMetricInfo{schema.GroupResource{Group: "extensions", Resource: "ingresses"}, true, "ingress_hits"},
|
|
provider.CustomMetricInfo{schema.GroupResource{Resource: "pods"}, true, "ingress_hits"},
|
|
provider.CustomMetricInfo{schema.GroupResource{Resource: "namespaces"}, false, "ingress_hits"},
|
|
provider.CustomMetricInfo{schema.GroupResource{Resource: "services"}, true, "service_proxy_packets"},
|
|
provider.CustomMetricInfo{schema.GroupResource{Resource: "namespaces"}, false, "service_proxy_packets"},
|
|
provider.CustomMetricInfo{schema.GroupResource{Group: "extensions", Resource: "deployments"}, true, "work_queue_wait"},
|
|
provider.CustomMetricInfo{schema.GroupResource{Resource: "namespaces"}, false, "work_queue_wait"},
|
|
provider.CustomMetricInfo{schema.GroupResource{Resource: "namespaces"}, false, "some_usage"},
|
|
provider.CustomMetricInfo{schema.GroupResource{Resource: "pods"}, true, "some_usage"},
|
|
))
|
|
})
|
|
})
|