Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 42 for PodCIDRs (0.12 sec)

  1. pkg/apis/core/v1/conversion_test.go

    	// core to v1
    	testInputs := []core.NodeSpec{
    		{
    			PodCIDRs: []string{"10.0.0.0/24", "10.0.1.0/24"},
    		},
    		{
    			PodCIDRs: nil,
    		},
    		{
    			PodCIDRs: []string{"10.0.0.0/24"},
    		},
    		{
    			PodCIDRs: []string{"ace:cab:deca::/8"},
    		},
    		{
    			PodCIDRs: []string{"10.0.0.0/24", "ace:cab:deca::/8"},
    		},
    		{
    			PodCIDRs: []string{"ace:cab:deca::/8", "10.0.0.0/24"},
    		},
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Mar 10 05:34:15 UTC 2023
    - 21.7K bytes
    - Viewed (0)
  2. pkg/proxy/node.go

    	n.mu.Lock()
    	defer n.mu.Unlock()
    
    	podCIDRs := node.Spec.PodCIDRs
    	// initialize podCIDRs
    	if len(n.podCIDRs) == 0 && len(podCIDRs) > 0 {
    		n.logger.Info("Setting current PodCIDRs", "podCIDRs", podCIDRs)
    		n.podCIDRs = podCIDRs
    		return
    	}
    	if !reflect.DeepEqual(n.podCIDRs, podCIDRs) {
    		n.logger.Error(nil, "Using NodeCIDR LocalDetector mode, current PodCIDRs are different than previous PodCIDRs, restarting",
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Apr 22 05:08:41 UTC 2024
    - 3.5K bytes
    - Viewed (0)
  3. pkg/controller/nodeipam/ipam/range_allocator_test.go

    			if len(updatedNode.Spec.PodCIDRs) == 0 {
    				continue // not assigned yet
    			}
    			//match
    			for podCIDRIdx, expectedPodCIDR := range tc.expectedAllocatedCIDR {
    				if updatedNode.Spec.PodCIDRs[podCIDRIdx] != expectedPodCIDR {
    					t.Errorf("%v: Unable to find allocated CIDR %v, found updated Nodes with CIDRs: %v", tc.description, expectedPodCIDR, updatedNode.Spec.PodCIDRs)
    					break
    				}
    			}
    		}
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 10:06:15 UTC 2024
    - 25.2K bytes
    - Viewed (0)
  4. staging/src/k8s.io/client-go/applyconfigurations/core/v1/nodespec.go

    // WithPodCIDRs adds the given value to the PodCIDRs field in the declarative configuration
    // and returns the receiver, so that objects can be build by chaining "With" function invocations.
    // If called multiple times, values provided by each call will be appended to the PodCIDRs field.
    func (b *NodeSpecApplyConfiguration) WithPodCIDRs(values ...string) *NodeSpecApplyConfiguration {
    	for i := range values {
    		b.PodCIDRs = append(b.PodCIDRs, values[i])
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 04 18:31:34 UTC 2021
    - 4.7K bytes
    - Viewed (0)
  5. pkg/apis/core/v1/conversion.go

    		return err
    	}
    	// If both fields (v1.PodCIDRs and v1.PodCIDR) are provided and differ, then PodCIDR is authoritative for compatibility with older clients
    	if (len(in.PodCIDR) > 0 && len(in.PodCIDRs) > 0) && (in.PodCIDR != in.PodCIDRs[0]) {
    		out.PodCIDRs = []string{in.PodCIDR}
    	}
    
    	// at the this point, autoConvert copied v1.PodCIDRs -> core.PodCIDRs
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Apr 19 22:30:55 UTC 2024
    - 19K bytes
    - Viewed (0)
  6. cmd/kube-proxy/app/server_linux_test.go

    		fakeWatch.Delete(oldNode)
    		// 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)
    	}
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sun Apr 28 15:51:23 UTC 2024
    - 21.9K bytes
    - Viewed (0)
  7. pkg/controller/nodeipam/ipam/range_allocator.go

    		return r.ReleaseCIDR(logger, node)
    	}
    	return r.AllocateOrOccupyCIDR(ctx, node)
    }
    
    // marks node.PodCIDRs[...] as used in allocator's tracked cidrSet
    func (r *rangeAllocator) occupyCIDRs(node *v1.Node) error {
    	if len(node.Spec.PodCIDRs) == 0 {
    		return nil
    	}
    	for idx, cidr := range node.Spec.PodCIDRs {
    		_, podCIDR, err := netutils.ParseCIDRSloppy(cidr)
    		if err != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 10:06:15 UTC 2024
    - 16.2K bytes
    - Viewed (0)
  8. pkg/proxy/node_test.go

    		},
    	}
    	for _, tt := range tests {
    		t.Run(tt.name, func(t *testing.T) {
    			n := &NodePodCIDRHandler{
    				podCIDRs: tt.oldNodePodCIDRs,
    			}
    			node := &v1.Node{
    				ObjectMeta: metav1.ObjectMeta{
    					Name:            "test-node",
    					ResourceVersion: "1",
    				},
    				Spec: v1.NodeSpec{
    					PodCIDRs: tt.newNodePodCIDRs,
    				},
    			}
    			defer func() {
    				r := recover()
    				if r == nil && tt.expectPanic {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sun Sep 10 16:50:29 UTC 2023
    - 3.5K bytes
    - Viewed (0)
  9. pkg/controller/nodeipam/ipam/doc.go

    // the CIDRAllocatorType):
    //   - RangeAllocator is an allocator that assigns PodCIDRs to nodes and works
    //     in conjunction with the RouteController to configure the network to get
    //     connectivity.
    //   - CloudAllocator is an allocator that synchronizes PodCIDRs from IP
    //     ranges assignments from the underlying cloud platform.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jul 26 17:14:05 UTC 2022
    - 1.4K bytes
    - Viewed (0)
  10. pkg/registry/core/node/strategy_test.go

    		"Node",
    		NodeToSelectableFields(&api.Node{}),
    		nil,
    	)
    }
    
    // helper creates a NodeNode with a set of PodCIDRs, Spec.ConfigSource, Status.Config
    func makeNode(podCIDRs []string, addSpecDynamicConfig bool, addStatusDynamicConfig bool) *api.Node {
    	node := &api.Node{
    		Spec: api.NodeSpec{
    			PodCIDRs: podCIDRs,
    		},
    	}
    	if addSpecDynamicConfig {
    		node.Spec.ConfigSource = &api.NodeConfigSource{}
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 12 15:48:03 UTC 2023
    - 9.7K bytes
    - Viewed (0)
Back to top