Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 62 for netutils (0.14 sec)

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

    					_, clusterCIDRv4, _ := netutils.ParseCIDRSloppy("127.123.234.0/8")
    					_, clusterCIDRv6, _ := netutils.ParseCIDRSloppy("ace:cab:deca::/84")
    					_, clusterCIDRv4_2, _ := netutils.ParseCIDRSloppy("10.0.0.0/8")
    					return []*net.IPNet{clusterCIDRv4, clusterCIDRv6, clusterCIDRv4_2}
    				}(),
    				ServiceCIDR: func() *net.IPNet {
    					_, serviceCIDR, _ := netutils.ParseCIDRSloppy("127.123.234.0/26")
    					return serviceCIDR
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 10:06:15 UTC 2024
    - 25.2K bytes
    - Viewed (0)
  2. pkg/proxy/util/nodeport_addresses_test.go

    					addrs: []net.Addr{
    						&net.IPNet{IP: netutils.ParseIPSloppy("1.2.3.4"), Mask: net.CIDRMask(30, 32)},
    						&net.IPNet{IP: netutils.ParseIPSloppy("2001:db8::1"), Mask: net.CIDRMask(64, 128)},
    					},
    				},
    				{
    					itf: net.Interface{Index: 1, MTU: 0, Name: "lo", HardwareAddr: nil, Flags: 0},
    					addrs: []net.Addr{
    						&net.IPNet{IP: netutils.ParseIPSloppy("127.0.0.1"), Mask: net.CIDRMask(8, 32)},
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 18 13:25:06 UTC 2024
    - 13.7K bytes
    - Viewed (0)
  3. cmd/kube-apiserver/app/options/validation_test.go

    	_, ipv4cidr, err := netutils.ParseCIDRSloppy("192.168.0.0/24")
    	if err != nil {
    		t.Fatalf("Unexpected error %v", err)
    	}
    
    	_, ipv6cidr, err := netutils.ParseCIDRSloppy("2001:db8::/112")
    	if err != nil {
    		t.Fatalf("Unexpected error %v", err)
    	}
    
    	ipv4address := netutils.ParseIPSloppy("192.168.1.1")
    	ipv6address := netutils.ParseIPSloppy("2001:db8::1")
    
    	tests := []struct {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 11.4K bytes
    - Viewed (0)
  4. pkg/registry/core/service/ipallocator/cidrallocator.go

    	address, _ := netip.AddrFromSlice(bytes)
    	return address
    }
    
    // Convert netutils.IPFamily to v1.IPFamily
    // TODO: consolidate helpers
    // copied from pkg/proxy/util/utils.go
    func convertToV1IPFamily(ipFamily netutils.IPFamily) v1.IPFamily {
    	switch ipFamily {
    	case netutils.IPv4:
    		return v1.IPv4Protocol
    	case netutils.IPv6:
    		return v1.IPv6Protocol
    	}
    
    	return v1.IPFamilyUnknown
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 13.2K bytes
    - Viewed (0)
  5. cmd/kube-proxy/app/server_test.go

    			rawNodeIPs: []net.IP{
    				netutils.ParseIPSloppy("90.90.90.90"),
    				netutils.ParseIPSloppy("2001:db8::2"),
    			},
    			bindAddress:    "::",
    			expectedFamily: v1.IPv4Protocol,
    			expectedIPv4:   "90.90.90.90",
    			expectedIPv6:   "2001:db8::2",
    		},
    		{
    			name: "Dual stack, primary IPv6",
    			rawNodeIPs: []net.IP{
    				netutils.ParseIPSloppy("2001:db8::2"),
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Apr 22 05:08:41 UTC 2024
    - 32.3K bytes
    - Viewed (0)
  6. pkg/proxy/winkernel/proxier_test.go

    	"k8s.io/apimachinery/pkg/types"
    	"k8s.io/apimachinery/pkg/util/intstr"
    	"k8s.io/kubernetes/pkg/proxy"
    	"k8s.io/kubernetes/pkg/proxy/healthcheck"
    	fakehcn "k8s.io/kubernetes/pkg/proxy/winkernel/testing"
    	netutils "k8s.io/utils/net"
    	"k8s.io/utils/ptr"
    )
    
    const (
    	testHostName      = "test-hostname"
    	testNetwork       = "TestNetwork"
    	ipAddress         = "10.0.0.1"
    	prefixLen         = 24
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sun Jan 28 14:30:51 UTC 2024
    - 30.2K bytes
    - Viewed (0)
  7. pkg/kubelet/certificate/kubelet.go

    			continue
    		}
    
    		switch address.Type {
    		case v1.NodeHostName:
    			if ip := netutils.ParseIPSloppy(address.Address); ip != nil {
    				seenIPs[address.Address] = true
    			} else {
    				seenDNSNames[address.Address] = true
    			}
    		case v1.NodeExternalIP, v1.NodeInternalIP:
    			if ip := netutils.ParseIPSloppy(address.Address); ip != nil {
    				seenIPs[address.Address] = true
    			}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Jun 06 03:07:16 UTC 2024
    - 10.3K bytes
    - Viewed (0)
  8. pkg/proxy/iptables/number_generated_rules_test.go

    	endpointSlices := make([]*discovery.EndpointSlice, nServices)
    
    	// base parameters
    	basePort := 80
    	base := netutils.BigForIP(netutils.ParseIPSloppy("10.0.0.1"))
    
    	// generate a base endpoint slice object
    	baseEp := netutils.BigForIP(netutils.ParseIPSloppy("172.16.0.1"))
    	epPort := 8080
    
    	eps := &discovery.EndpointSlice{
    		ObjectMeta: metav1.ObjectMeta{
    			Name:      "ep",
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 21 14:39:54 UTC 2024
    - 13.1K bytes
    - Viewed (0)
  9. pkg/proxy/apis/config/validation/validation.go

    		case len(cidrs) == 2:
    			isDual, err := netutils.IsDualStackCIDRStrings(cidrs)
    			if err != nil || !isDual {
    				allErrs = append(allErrs, field.Invalid(newPath.Child("ClusterCIDR"), config.ClusterCIDR, "must be a valid DualStack CIDR (e.g. 10.100.0.0/16,fde4:8dba:82e1::/48)"))
    			}
    		// if we are here means that len(cidrs) == 1, we need to validate it
    		default:
    			if _, _, err := netutils.ParseCIDRSloppy(config.ClusterCIDR); err != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 18 13:25:06 UTC 2024
    - 14.6K bytes
    - Viewed (0)
  10. cmd/kubeadm/app/preflight/checks.go

    		if !IPV4Check && netutils.IsIPv4CIDRString(cidr) {
    			IPV4Check = true
    		}
    		if !IPV6Check && netutils.IsIPv6CIDRString(cidr) {
    			IPV6Check = true
    		}
    
    	}
    	cidrs = strings.Split(cfg.Networking.PodSubnet, ",")
    	for _, cidr := range cidrs {
    		checks = append(checks, HTTPProxyCIDRCheck{Proto: "https", CIDR: cidr})
    		if !IPV4Check && netutils.IsIPv4CIDRString(cidr) {
    			IPV4Check = true
    		}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Jun 03 11:20:55 UTC 2024
    - 39.5K bytes
    - Viewed (0)
Back to top