github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-08-07 03:03:59 +00:00
Code Issues Projects Releases Wiki Activity

kubelet: migrate pkg/kubelet/cloudresource to structured logging

Browse Source
This commit is contained in:
Sladyn Nunes 2021-02-11 18:59:09 +05:30
parent 42c1ccb38e
commit 5ba3bf1bca
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
} }