github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-07-25 20:53:33 +00:00
Code Issues Projects Releases Wiki Activity

Merge pull request #98999 from sladyn98/structured-logging

Browse Source 
kubelet: migrate pkg/kubelet/cloudresource to structured logging
This commit is contained in:
Kubernetes Prow Robot 2021-03-08 22:53:23 -08:00 committed by GitHub
commit c7389c1f35
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
pkg/kubelet/cloudresource/cloud_request_manager.go
View File

@ -82,7 +82,7 @@ func (m *cloudResourceSyncManager) NodeAddresses() ([]v1.NodeAddress, error) {
if addrs, err := m.nodeAddresses, m.nodeAddressesErr; len(addrs) > 0 || err != nil { if addrs, err := m.nodeAddresses, m.nodeAddressesErr; len(addrs) > 0 || err != nil {
return addrs, err return addrs, err
} }
klog.V(5).Infof("Waiting for cloud provider to provide node addresses") klog.V(5).InfoS("Waiting for cloud provider to provide node addresses")
m.nodeAddressesMonitor.Wait() m.nodeAddressesMonitor.Wait()
} }
} }
@ -103,7 +103,7 @@ func (m *cloudResourceSyncManager) getNodeAddresses() ([]v1.NodeAddress, error)
} }
func (m *cloudResourceSyncManager) syncNodeAddresses() { func (m *cloudResourceSyncManager) syncNodeAddresses() {
klog.V(5).Infof("Requesting node addresses from cloud provider for node %q", m.nodeName) klog.V(5).InfoS("Requesting node addresses from cloud provider for node", "nodeName", m.nodeName)
addrs, err := m.getNodeAddresses() addrs, err := m.getNodeAddresses()
@ -112,7 +112,7 @@ func (m *cloudResourceSyncManager) syncNodeAddresses() {
defer m.nodeAddressesMonitor.Broadcast() defer m.nodeAddressesMonitor.Broadcast()
if err != nil { if err != nil {
klog.V(2).Infof("Node addresses from cloud provider for node %q not collected: %v", m.nodeName, err) klog.V(2).InfoS("Node addresses from cloud provider for node not collected", "nodeName", m.nodeName, "err", err)
if len(m.nodeAddresses) > 0 { if len(m.nodeAddresses) > 0 {
// in the event that a sync loop fails when a previous sync had // in the event that a sync loop fails when a previous sync had
@ -124,7 +124,7 @@ func (m *cloudResourceSyncManager) syncNodeAddresses() {
return return
} }
klog.V(5).Infof("Node addresses from cloud provider for node %q collected", m.nodeName) klog.V(5).InfoS("Node addresses from cloud provider for node collected", "nodeName", m.nodeName)
m.nodeAddressesErr = nil m.nodeAddressesErr = nil
m.nodeAddresses = addrs m.nodeAddresses = addrs
} }