mudhorn/prometheus
1
0
Fork 0
mirror of https://github.com/prometheus/prometheus.git synced 2025-03-05 20:59:13 -08:00
Code Issues Actions 4 Packages Projects Releases Wiki Activity

Add Kubernetes-SD metrics.

Browse source
This commit is contained in:
Dominik Schulz 2016-10-21 10:48:28 +02:00
parent 552ab61fa1
commit e1e30f12cd
5 changed files with 45 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

3
retrieval/discovery/kubernetes/endpoints.go
View file

@ -83,12 +83,15 @@ func (e *Endpoints) Run(ctx context.Context, ch chan<- []*config.TargetGroup) {
e.endpointsInf.AddEventHandler(cache.ResourceEventHandlerFuncs{ e.endpointsInf.AddEventHandler(cache.ResourceEventHandlerFuncs{
AddFunc: func(o interface{}) { AddFunc: func(o interface{}) {
eventCount.WithLabelValues("endpoint", "add").Inc()
send(e.buildEndpoints(o.(*apiv1.Endpoints))) send(e.buildEndpoints(o.(*apiv1.Endpoints)))
}, },
UpdateFunc: func(_, o interface{}) { UpdateFunc: func(_, o interface{}) {
eventCount.WithLabelValues("endpoint", "update").Inc()
send(e.buildEndpoints(o.(*apiv1.Endpoints))) send(e.buildEndpoints(o.(*apiv1.Endpoints)))
}, },
DeleteFunc: func(o interface{}) { DeleteFunc: func(o interface{}) {
eventCount.WithLabelValues("endpoint", "delete").Inc()
send(&config.TargetGroup{Source: endpointsSource(o.(*apiv1.Endpoints).ObjectMeta)}) send(&config.TargetGroup{Source: endpointsSource(o.(*apiv1.Endpoints).ObjectMeta)})
}, },
}) })

33
retrieval/discovery/kubernetes/kubernetes.go
View file

@ -17,6 +17,7 @@ import (
"io/ioutil" "io/ioutil"
"time" "time"
"github.com/prometheus/client_golang/prometheus"
"github.com/prometheus/prometheus/config" "github.com/prometheus/prometheus/config"
"github.com/prometheus/common/log" "github.com/prometheus/common/log"
@ -35,8 +36,40 @@ const (
// in this discovery. // in this discovery.
metaLabelPrefix = model.MetaLabelPrefix + "kubernetes_" metaLabelPrefix = model.MetaLabelPrefix + "kubernetes_"
namespaceLabel = metaLabelPrefix + "namespace" namespaceLabel = metaLabelPrefix + "namespace"
// Constants for instrumentation.
namespace = "prometheus"
) )
var (
eventCount = prometheus.NewCounterVec(
prometheus.CounterOpts{
Namespace: namespace,
Name: "sd_kubernetes_events_total",
Help: "The number of Kubernetes events received.",
},
[]string{"type", "event"},
)
)
func init() {
prometheus.MustRegister(eventCount)
// Initialize metric vectors.
eventCount.WithLabelValues("endpoint", "add")
eventCount.WithLabelValues("endpoint", "delete")
eventCount.WithLabelValues("endpoint", "update")
eventCount.WithLabelValues("node", "add")
eventCount.WithLabelValues("node", "delete")
eventCount.WithLabelValues("node", "update")
eventCount.WithLabelValues("pod", "add")
eventCount.WithLabelValues("pod", "delete")
eventCount.WithLabelValues("pod", "update")
eventCount.WithLabelValues("service", "add")
eventCount.WithLabelValues("service", "delete")
eventCount.WithLabelValues("service", "update")
}
// Kubernetes implements the TargetProvider interface for discovering // Kubernetes implements the TargetProvider interface for discovering
// targets from Kubernetes. // targets from Kubernetes.
type Kubernetes struct { type Kubernetes struct {

3
retrieval/discovery/kubernetes/node.go
View file

@ -63,12 +63,15 @@ func (n *Node) Run(ctx context.Context, ch chan<- []*config.TargetGroup) {
} }
n.informer.AddEventHandler(cache.ResourceEventHandlerFuncs{ n.informer.AddEventHandler(cache.ResourceEventHandlerFuncs{
AddFunc: func(o interface{}) { AddFunc: func(o interface{}) {
eventCount.WithLabelValues("node", "add").Inc()
send(n.buildNode(o.(*apiv1.Node))) send(n.buildNode(o.(*apiv1.Node)))
}, },
DeleteFunc: func(o interface{}) { DeleteFunc: func(o interface{}) {
eventCount.WithLabelValues("node", "delete").Inc()
send(&config.TargetGroup{Source: nodeSource(o.(*apiv1.Node))}) send(&config.TargetGroup{Source: nodeSource(o.(*apiv1.Node))})
}, },
UpdateFunc: func(_, o interface{}) { UpdateFunc: func(_, o interface{}) {
eventCount.WithLabelValues("node", "update").Inc()
send(n.buildNode(o.(*apiv1.Node))) send(n.buildNode(o.(*apiv1.Node)))
}, },
}) })

3
retrieval/discovery/kubernetes/pod.go
View file

@ -71,12 +71,15 @@ func (p *Pod) Run(ctx context.Context, ch chan<- []*config.TargetGroup) {
} }
p.informer.AddEventHandler(cache.ResourceEventHandlerFuncs{ p.informer.AddEventHandler(cache.ResourceEventHandlerFuncs{
AddFunc: func(o interface{}) { AddFunc: func(o interface{}) {
eventCount.WithLabelValues("pod", "add").Inc()
send(p.buildPod(o.(*apiv1.Pod))) send(p.buildPod(o.(*apiv1.Pod)))
}, },
DeleteFunc: func(o interface{}) { DeleteFunc: func(o interface{}) {
eventCount.WithLabelValues("pod", "delete").Inc()
send(&config.TargetGroup{Source: podSource(o.(*apiv1.Pod))}) send(&config.TargetGroup{Source: podSource(o.(*apiv1.Pod))})
}, },
UpdateFunc: func(_, o interface{}) { UpdateFunc: func(_, o interface{}) {
eventCount.WithLabelValues("pod", "update").Inc()
send(p.buildPod(o.(*apiv1.Pod))) send(p.buildPod(o.(*apiv1.Pod)))
}, },
}) })

3
retrieval/discovery/kubernetes/service.go
View file

@ -61,12 +61,15 @@ func (s *Service) Run(ctx context.Context, ch chan<- []*config.TargetGroup) {
} }
s.informer.AddEventHandler(cache.ResourceEventHandlerFuncs{ s.informer.AddEventHandler(cache.ResourceEventHandlerFuncs{
AddFunc: func(o interface{}) { AddFunc: func(o interface{}) {
eventCount.WithLabelValues("service", "add").Inc()
send(s.buildService(o.(*apiv1.Service))) send(s.buildService(o.(*apiv1.Service)))
}, },
DeleteFunc: func(o interface{}) { DeleteFunc: func(o interface{}) {
eventCount.WithLabelValues("service", "delete").Inc()
send(&config.TargetGroup{Source: serviceSource(o.(*apiv1.Service))}) send(&config.TargetGroup{Source: serviceSource(o.(*apiv1.Service))})
}, },
UpdateFunc: func(_, o interface{}) { UpdateFunc: func(_, o interface{}) {
eventCount.WithLabelValues("service", "update").Inc()
send(s.buildService(o.(*apiv1.Service))) send(s.buildService(o.(*apiv1.Service)))
}, },
}) })