- Sort Score
- Result 10 results
- Languages All
Results 1 - 2 of 2 for syncNodeAddresses (0.29 sec)
-
pkg/kubelet/cloudresource/cloud_request_manager.go
if !ok { return nil, fmt.Errorf("failed to get instances from cloud provider") } return instances.NodeAddresses(context.TODO(), m.nodeName) } func (m *cloudResourceSyncManager) syncNodeAddresses() { klog.V(5).InfoS("Requesting node addresses from cloud provider for node", "nodeName", m.nodeName) addrs, err := m.getNodeAddresses() m.nodeAddressesMonitor.L.Lock()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 05 18:29:23 UTC 2021 - 4.5K bytes - Viewed (0) -
pkg/kubelet/cloudresource/cloud_request_manager_test.go
cloud.Err = test.err if test.shouldDisableInstances { cloud.DisableInstances = true defer func() { cloud.DisableInstances = false }() } manager.syncNodeAddresses() nodeAddresses, err := manager.NodeAddresses() if (err != nil) != test.wantErr { t.Errorf("unexpected err: %v", err) } if got, want := nodeAddresses, test.wantAddrs; !reflect.DeepEqual(got, want) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 12 15:48:03 UTC 2023 - 4.2K bytes - Viewed (0)