Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for CIDRSet (0.24 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)
Back to top