Skip to content

K
k3s
Commit 40249c06 authored by Kubernetes Submit Queue's avatar Kubernetes Submit Queue Committed by GitHub
Browse files
Options

Merge pull request #49366 from gmarek/coreEvents

Automatic merge from submit-queue Explicitly use Core() client when creating eventClint @sttts
parents 3d94338e 45b47c7f
Hide whitespace changes
Inline Side-by-side
Showing with 5 additions and 3 deletions
cmd/kube-proxy/app/server.go
View file @ 40249c06
...@@ -413,7 +413,7 @@ func createClients(config componentconfig.ClientConnectionConfiguration, masterO ...@@ -413,7 +413,7 @@ func createClients(config componentconfig.ClientConnectionConfiguration, masterO
return nil, nil, err return nil, nil, err
} }
return client, eventClient, nil return client, eventClient.Core(), nil
} }
// NewProxyServer returns a new ProxyServer. // NewProxyServer returns a new ProxyServer.
......
cmd/kubelet/app/server.go
View file @ 40249c06
...@@ -485,10 +485,12 @@ func run(s *options.KubeletServer, kubeDeps *kubelet.Dependencies) (err error) { ...@@ -485,10 +485,12 @@ func run(s *options.KubeletServer, kubeDeps *kubelet.Dependencies) (err error) {
eventClientConfig := *clientConfig eventClientConfig := *clientConfig
eventClientConfig.QPS = float32(s.EventRecordQPS) eventClientConfig.QPS = float32(s.EventRecordQPS)
eventClientConfig.Burst = int(s.EventBurst) eventClientConfig.Burst = int(s.EventBurst)
eventClient, err = clientgoclientset.NewForConfig(&eventClientConfig) tmpClient, err := clientgoclientset.NewForConfig(&eventClientConfig)
if err != nil { if err != nil {
glog.Warningf("Failed to create API Server client: %v", err) glog.Warningf("Failed to create API Server client for Events: %v", err)
} }
eventClient = tmpClient.Core()
} else { } else {
switch { switch {
case s.RequireKubeConfig: case s.RequireKubeConfig:
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment