Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for syncNodeAddresses (0.29 sec)

  1. 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)
  2. 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)
Back to top