DevFW-CICD/ingress-nginx-helm
14
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Change recorder event scheme

Browse source
This commit is contained in:
Manuel de Brito Fontes 2017-05-24 14:02:51 -04:00
parent e347413649
commit 797560ab8c
2 changed files with 4 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
core/pkg/ingress/controller/controller.go
View file

@ -32,8 +32,8 @@ import (
"k8s.io/apimachinery/pkg/util/intstr" "k8s.io/apimachinery/pkg/util/intstr"
"k8s.io/apimachinery/pkg/util/wait" "k8s.io/apimachinery/pkg/util/wait"
clientset "k8s.io/client-go/kubernetes" clientset "k8s.io/client-go/kubernetes"
"k8s.io/client-go/kubernetes/scheme"
unversionedcore "k8s.io/client-go/kubernetes/typed/core/v1" unversionedcore "k8s.io/client-go/kubernetes/typed/core/v1"
def_api "k8s.io/client-go/pkg/api"
api "k8s.io/client-go/pkg/api/v1" api "k8s.io/client-go/pkg/api/v1"
extensions "k8s.io/client-go/pkg/apis/extensions/v1beta1" extensions "k8s.io/client-go/pkg/apis/extensions/v1beta1"
"k8s.io/client-go/tools/cache" "k8s.io/client-go/tools/cache"
@ -153,7 +153,7 @@ func newIngressController(config *Configuration) *GenericController {
stopLock: &sync.Mutex{}, stopLock: &sync.Mutex{},
stopCh: make(chan struct{}), stopCh: make(chan struct{}),
syncRateLimiter: flowcontrol.NewTokenBucketRateLimiter(0.5, 1), syncRateLimiter: flowcontrol.NewTokenBucketRateLimiter(0.5, 1),
recorder: eventBroadcaster.NewRecorder(def_api.Scheme, api.EventSource{ recorder: eventBroadcaster.NewRecorder(scheme.Scheme, api.EventSource{
Component: "ingress-controller", Component: "ingress-controller",
}), }),
sslCertTracker: newSSLCertTracker(), sslCertTracker: newSSLCertTracker(),

4
core/pkg/ingress/status/election.go
View file

@ -26,7 +26,7 @@ import (
"k8s.io/apimachinery/pkg/api/errors" "k8s.io/apimachinery/pkg/api/errors"
meta_v1 "k8s.io/apimachinery/pkg/apis/meta/v1" meta_v1 "k8s.io/apimachinery/pkg/apis/meta/v1"
client "k8s.io/client-go/kubernetes" client "k8s.io/client-go/kubernetes"
def_api "k8s.io/client-go/pkg/api" "k8s.io/client-go/kubernetes/scheme"
api "k8s.io/client-go/pkg/api/v1" api "k8s.io/client-go/pkg/api/v1"
"k8s.io/client-go/tools/record" "k8s.io/client-go/tools/record"
@ -96,7 +96,7 @@ func NewElection(electionID,
if err != nil { if err != nil {
return nil, err return nil, err
} }
recorder := broadcaster.NewRecorder(def_api.Scheme, api.EventSource{ recorder := broadcaster.NewRecorder(scheme.Scheme, api.EventSource{
Component: "ingress-leader-elector", Component: "ingress-leader-elector",
Host: hostname, Host: hostname,
}) })