Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 8 of 8 for cidrSet (0.16 sec)

  1. pkg/controller/nodeipam/ipam/range_allocator.go

    	// create a cidrSet for each cidr we operate on
    	// cidrSet are mapped to clusterCIDR by index
    	cidrSets := make([]*cidrset.CidrSet, len(allocatorParams.ClusterCIDRs))
    	for idx, cidr := range allocatorParams.ClusterCIDRs {
    		cidrSet, err := cidrset.NewCIDRSet(cidr, allocatorParams.NodeCIDRMaskSizes[idx])
    		if err != nil {
    			return nil, err
    		}
    		cidrSets[idx] = cidrSet
    	}
    
    	ra := &rangeAllocator{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 10:06:15 UTC 2024
    - 16.2K bytes
    - Viewed (0)
  2. pkg/controller/nodeipam/ipam/cidrset/cidr_set_test.go

    }
    
    func TestCidrSetMetricsDual(t *testing.T) {
    	// create IPv4 cidrSet
    	cidrIPv4 := "10.0.0.0/16"
    	_, clusterCIDRv4, _ := netutils.ParseCIDRSloppy(cidrIPv4)
    	clearMetrics(map[string]string{"clusterCIDR": cidrIPv4})
    
    	a, err := NewCIDRSet(clusterCIDRv4, 24)
    	if err != nil {
    		t.Fatalf("unexpected error creating CidrSet: %v", err)
    	}
    
    	clusterMaskSize, _ := clusterCIDRv4.Mask.Size()
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu May 11 08:53:03 UTC 2023
    - 29.5K bytes
    - Viewed (0)
  3. pkg/controller/nodeipam/ipam/sync/sync.go

    	kubeAPI    kubeAPI
    	mode       NodeSyncMode
    	nodeName   string
    	opChan     chan syncOp
    	set        *cidrset.CidrSet
    }
    
    // New returns a new syncer for a given node.
    func New(c controller, cloudAlias cloudAlias, kubeAPI kubeAPI, mode NodeSyncMode, nodeName string, set *cidrset.CidrSet) *NodeSync {
    	return &NodeSync{
    		c:          c,
    		cloudAlias: cloudAlias,
    		kubeAPI:    kubeAPI,
    		mode:       mode,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Mar 07 07:50:01 UTC 2023
    - 12.6K bytes
    - Viewed (0)
  4. pkg/registry/core/service/ipallocator/bitmap_test.go

    	if err != nil {
    		t.Fatalf("unexpected error creating CidrSet: %v", err)
    	}
    	a.EnableMetrics()
    	// create IPv6 allocator
    	cidrIPv6 := "2001:db8::/112"
    	_, clusterCIDRv6, _ := netutils.ParseCIDRSloppy(cidrIPv6)
    	b, err := NewInMemory(clusterCIDRv6)
    	b.EnableMetrics()
    	if err != nil {
    		t.Fatalf("unexpected error creating CidrSet: %v", err)
    	}
    
    	// Check initial state
    	em := testMetrics{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jan 25 20:32:40 UTC 2023
    - 21.1K bytes
    - Viewed (0)
  5. pkg/registry/core/service/ipallocator/ipallocator_test.go

    	// create IPv6 allocator
    	cidrIPv6 := "2001:db8::/112"
    	_, clusterCIDRv6, _ := netutils.ParseCIDRSloppy(cidrIPv6)
    	b, err := newTestAllocator(clusterCIDRv6)
    	if err != nil {
    		t.Fatalf("unexpected error creating CidrSet: %v", err)
    	}
    	b.EnableMetrics()
    
    	// Check initial state
    	em := testMetrics{
    		free:      0,
    		used:      0,
    		allocated: 0,
    		errors:    0,
    	}
    	expectMetrics(t, cidrIPv4, em)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sun Jun 25 13:14:46 UTC 2023
    - 24.2K bytes
    - Viewed (0)
  6. pkg/registry/core/service/ipallocator/cidrallocator.go

    		treeSet.Insert(k.String())
    		return false
    	})
    	c.muTree.Unlock()
    	cidrsToRemove := treeSet.Difference(cidrsSet)
    	cidrsToAdd := cidrsSet.Difference(treeSet)
    
    	errs := []error{}
    	// Add new allocators
    	for _, cidr := range cidrsToAdd.UnsortedList() {
    		_, ipnet, err := netutils.ParseCIDRSloppy(cidr)
    		if err != nil {
    			return err
    		}
    		// New ServiceCIDR, create new allocator
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 13.2K bytes
    - Viewed (0)
  7. pkg/controller/nodeipam/ipam/range_allocator_test.go

    				_, cidr, err := netutils.ParseCIDRSloppy(allocated)
    				if err != nil {
    					t.Fatalf("%v: unexpected error when parsing CIDR %v: %v", tc.description, allocated, err)
    				}
    				if err = rangeAllocator.cidrSets[idx].Occupy(cidr); err != nil {
    					t.Fatalf("%v: unexpected error when occupying CIDR %v: %v", tc.description, allocated, err)
    				}
    			}
    		}
    
    		updateCount := 0
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 10:06:15 UTC 2024
    - 25.2K bytes
    - Viewed (0)
  8. pkg/kubelet/pleg/generic.go

    }
    
    func getContainersFromPods(pods ...*kubecontainer.Pod) []*kubecontainer.Container {
    	cidSet := sets.New[string]()
    	var containers []*kubecontainer.Container
    	fillCidSet := func(cs []*kubecontainer.Container) {
    		for _, c := range cs {
    			cid := c.ID.ID
    			if cidSet.Has(cid) {
    				continue
    			}
    			cidSet.Insert(cid)
    			containers = append(containers, c)
    		}
    	}
    
    	for _, p := range pods {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 19.3K bytes
    - Viewed (0)
Back to top