RepoMirrors
/
prometheus
mirror of https://github.com/prometheus/prometheus
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

k8s: Use versioned struct for ingress discovery

This commit is contained in:
Johannes 'fish' Ziemke 2017-09-06 12:47:03 +02:00
parent 70f3d1e9f9
commit 75aec7d970
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
discovery/kubernetes/kubernetes.go
View File

@ -28,7 +28,7 @@ import (
"k8s.io/client-go/kubernetes" "k8s.io/client-go/kubernetes"
"k8s.io/client-go/pkg/api" "k8s.io/client-go/pkg/api"
apiv1 "k8s.io/client-go/pkg/api/v1" apiv1 "k8s.io/client-go/pkg/api/v1"
"k8s.io/client-go/pkg/apis/extensions" extensionsv1beta1 "k8s.io/client-go/pkg/apis/extensions/v1beta1"
"k8s.io/client-go/rest" "k8s.io/client-go/rest"
"k8s.io/client-go/tools/cache" "k8s.io/client-go/tools/cache"
) )
@ -244,7 +244,7 @@ func (d *Discovery) Run(ctx context.Context, ch chan<- []*config.TargetGroup) {
ilw := cache.NewListWatchFromClient(reclient, "ingresses", namespace, nil) ilw := cache.NewListWatchFromClient(reclient, "ingresses", namespace, nil)
ingress := NewIngress( ingress := NewIngress(
d.logger.With("kubernetes_sd", "ingress"), d.logger.With("kubernetes_sd", "ingress"),
cache.NewSharedInformer(ilw, &extensions.Ingress{}, resyncPeriod), cache.NewSharedInformer(ilw, &extensionsv1beta1.Ingress{}, resyncPeriod),
) )
go ingress.informer.Run(ctx.Done()) go ingress.informer.Run(ctx.Done())