Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for waitForPodCIDR (0.6 sec)

  1. cmd/kube-proxy/app/server_linux_test.go

    		// set the PodCIDRs on the new node
    		fakeWatch.Modify(updatedNode)
    	}()
    	got, err := waitForPodCIDR(ctx, client, node.Name)
    	if err != nil {
    		t.Errorf("waitForPodCIDR() unexpected error %v", err)
    		return
    	}
    	if !reflect.DeepEqual(got.Spec.PodCIDRs, expected) {
    		t.Errorf("waitForPodCIDR() got %v expected to be %v ", got.Spec.PodCIDRs, expected)
    	}
    }
    
    func TestGetConntrackMax(t *testing.T) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sun Apr 28 15:51:23 UTC 2024
    - 21.9K bytes
    - Viewed (0)
  2. cmd/kube-proxy/app/server_linux.go

    	logger := klog.FromContext(ctx)
    	if s.Config.DetectLocalMode == proxyconfigapi.LocalModeNodeCIDR {
    		logger.Info("Watching for node, awaiting podCIDR allocation", "hostname", s.Hostname)
    		node, err := waitForPodCIDR(ctx, s.Client, s.Hostname)
    		if err != nil {
    			return err
    		}
    		s.podCIDRs = node.Spec.PodCIDRs
    		logger.Info("NodeInfo", "podCIDRs", node.Spec.PodCIDRs)
    	}
    
    	err := s.setupConntrack(ctx)
    	if err != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Jun 08 13:48:54 UTC 2024
    - 18.1K bytes
    - Viewed (0)
Back to top