- Sort Score
- Result 10 results
- Languages All
Results 1 - 8 of 8 for cidrSet (0.16 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)