mirror of
https://github.com/k3s-io/kubernetes.git
synced 2025-07-27 13:37:30 +00:00
Apply suggestions from code review
Co-authored-by: Marek Siarkowicz <marek.siarkowicz@protonmail.com>
This commit is contained in:
parent
5ba3bf1bca
commit
cee2c42a54
@ -103,7 +103,7 @@ func (m *cloudResourceSyncManager) getNodeAddresses() ([]v1.NodeAddress, error)
|
|||||||
}
|
}
|
||||||
|
|
||||||
func (m *cloudResourceSyncManager) syncNodeAddresses() {
|
func (m *cloudResourceSyncManager) syncNodeAddresses() {
|
||||||
klog.V(5).InfoS("Requesting node addresses from cloud provider for node","nodeName", 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).InfoS("Node addresses from cloud provider for node not collected","nodeName", m.nodeName, "err", 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).InfoS("Node addresses from cloud provider for node collected","nodeName", 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
|
||||||
}
|
}
|
||||||
|
Loading…
Reference in New Issue
Block a user