Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 16 of 16 for cidrSet (0.14 sec)

  1. pilot/pkg/networking/core/listener.go

    				continue
    			}
    
    			if s == "*" {
    				continue
    			}
    			res.Insert(prefix.Masked().String())
    		}
    		return res
    	}
    	return cidrSet(a.destinationCIDRs).Equals(cidrSet(b.destinationCIDRs))
    }
    
    func (chain *filterChainOpts) toFilterChainMatch() *listener.FilterChainMatch {
    	if chain.isMatchAll() {
    		return nil
    	}
    	match := &listener.FilterChainMatch{
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon May 06 04:44:06 UTC 2024
    - 55.1K bytes
    - Viewed (0)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. CHANGELOG/CHANGELOG-1.19.md

    - Reduce event spam during a volume operation error. ([#89794](https://github.com/kubernetes/kubernetes/pull/89794), [@msau42](https://github.com/msau42)) [SIG Storage]
    - Refactor the local nodeipam range allocator and instrument the cidrset used to store the allocated CIDRs with the following metrics:
      "cidrset_cidrs_allocations_total",
      "cidrset_cidrs_releases_total",
      "cidrset_usage_cidrs",
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jan 05 05:42:32 UTC 2022
    - 489.7K bytes
    - Viewed (0)
Back to top