Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 46 for IPv4Protocol (0.35 sec)

  1. pkg/proxy/util/nodeport_addresses.go

    	npa := &NodePortAddresses{}
    
    	// Filter CIDRs to correct family
    	for _, str := range cidrStrings {
    		if (family == v1.IPv4Protocol) == netutils.IsIPv4CIDRString(str) {
    			npa.cidrStrings = append(npa.cidrStrings, str)
    		}
    	}
    	if len(npa.cidrStrings) == 0 {
    		if family == v1.IPv4Protocol {
    			npa.cidrStrings = []string{IPv4ZeroCIDR}
    		} else {
    			npa.cidrStrings = []string{IPv6ZeroCIDR}
    		}
    	}
    
    	// Now parse
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 18 13:25:06 UTC 2024
    - 3.6K bytes
    - Viewed (0)
  2. cmd/kube-proxy/app/server_linux.go

    		localDetectors[v1.IPv4Protocol] = localDetector
    		localDetectors[v1.IPv6Protocol] = localDetector
    
    	case proxyconfigapi.LocalModeInterfaceNamePrefix:
    		localDetector := proxyutil.NewDetectLocalByInterfaceNamePrefix(config.DetectLocal.InterfaceNamePrefix)
    		localDetectors[v1.IPv4Protocol] = localDetector
    		localDetectors[v1.IPv6Protocol] = localDetector
    
    	default:
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Jun 08 13:48:54 UTC 2024
    - 18.1K bytes
    - Viewed (0)
  3. pkg/proxy/endpointschangetracker_test.go

    			endpointsChangeTracker: NewEndpointsChangeTracker("", nil, v1.IPv4Protocol, nil, nil),
    			expectedChanges:        []*endpointsChange{},
    			appliedSlices:          []*discovery.EndpointSlice{},
    			pendingSlices:          []*discovery.EndpointSlice{},
    		},
    		"adding initial slice": {
    			endpointsChangeTracker: NewEndpointsChangeTracker("", nil, v1.IPv4Protocol, nil, nil),
    			expectedChanges: []*endpointsChange{{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Dec 21 14:44:08 UTC 2023
    - 79.9K bytes
    - Viewed (0)
  4. pkg/proxy/ipvs/proxier_test.go

    			ipt := iptablestest.NewFake()
    			ipvs := ipvstest.NewFake()
    			ipset := ipsettest.NewFake(testIPSetVersion)
    			fp := NewFakeProxier(ctx, ipt, ipvs, ipset, test.nodeIPs, nil, v1.IPv4Protocol)
    			fp.nodePortAddresses = proxyutil.NewNodePortAddresses(v1.IPv4Protocol, test.nodePortAddresses)
    
    			makeServiceMap(fp, test.services...)
    			populateEndpointSlices(fp, test.endpoints...)
    
    			fp.syncProxyRules()
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Apr 27 01:31:57 UTC 2024
    - 186.8K bytes
    - Viewed (0)
  5. pkg/proxy/util/utils.go

    	switch ipFamily {
    	case netutils.IPv4:
    		return v1.IPv4Protocol
    	case netutils.IPv6:
    		return v1.IPv6Protocol
    	}
    
    	return v1.IPFamilyUnknown
    }
    
    // OtherIPFamily returns the other ip family
    func OtherIPFamily(ipFamily v1.IPFamily) v1.IPFamily {
    	if ipFamily == v1.IPv6Protocol {
    		return v1.IPv4Protocol
    	}
    
    	return v1.IPv6Protocol
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon May 20 11:57:43 UTC 2024
    - 7.4K bytes
    - Viewed (0)
  6. pkg/proxy/nftables/proxier_test.go

    		// node IP to be accepted
    		allowAltNodeIP bool
    	}{
    		{
    			name: "ipv4",
    
    			family:            v1.IPv4Protocol,
    			nodePortAddresses: nil,
    
    			allowAltNodeIP: false,
    		},
    		{
    			name: "ipv4, multiple nodeport-addresses",
    
    			family:            v1.IPv4Protocol,
    			nodePortAddresses: []string{"192.168.0.0/24", "192.168.1.0/24", "2001:db8::/64"},
    
    			allowAltNodeIP: true,
    		},
    		{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Apr 27 01:31:57 UTC 2024
    - 173.5K bytes
    - Viewed (0)
  7. pkg/registry/core/service/ipallocator/controller/repair.go

    	networkByFamily := make(map[v1.IPFamily]*net.IPNet)
    	allocatorByFamily := make(map[v1.IPFamily]rangeallocation.RangeRegistry)
    	leaksByFamily := make(map[v1.IPFamily]map[string]int)
    
    	primary := v1.IPv4Protocol
    	secondary := v1.IPv6Protocol
    	if netutils.IsIPv6(network.IP) {
    		primary = v1.IPv6Protocol
    	}
    
    	networkByFamily[primary] = network
    	allocatorByFamily[primary] = alloc
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Sep 30 15:46:06 UTC 2023
    - 13.8K bytes
    - Viewed (0)
  8. pkg/controller/endpointslice/endpointslice_controller_test.go

    						{Name: "sctp-example", TargetPort: intstr.FromInt32(3456), Protocol: v1.ProtocolSCTP},
    					},
    					Selector:   map[string]string{"foo": "bar"},
    					IPFamilies: []v1.IPFamily{v1.IPv4Protocol},
    				},
    			},
    			pods: []*v1.Pod{
    				{
    					ObjectMeta: metav1.ObjectMeta{
    						Namespace:         "default",
    						Name:              "pod0",
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 08:33:32 UTC 2024
    - 65.5K bytes
    - Viewed (0)
  9. pkg/registry/core/service/storage/alloc.go

    				// add the alt ipfamily
    				if service.Spec.IPFamilies[0] == api.IPv4Protocol {
    					service.Spec.IPFamilies = append(service.Spec.IPFamilies, api.IPv6Protocol)
    				} else {
    					service.Spec.IPFamilies = append(service.Spec.IPFamilies, api.IPv4Protocol)
    				}
    			}
    		}
    
    		// nothing more needed here
    		return nil
    	}
    
    	//
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Oct 31 21:05:05 UTC 2023
    - 37.3K bytes
    - Viewed (0)
  10. pkg/registry/core/service/ipallocator/cidrallocator.go

    	ipAddressInformer networkingv1alpha1informers.IPAddressInformer,
    	isIPv6 bool,
    ) (*MetaAllocator, error) {
    
    	// TODO: make the NewMetaAllocator agnostic of the IP family
    	family := api.IPv4Protocol
    	if isIPv6 {
    		family = api.IPv6Protocol
    	}
    
    	c := &MetaAllocator{
    		client:            client,
    		serviceCIDRLister: serviceCIDRInformer.Lister(),
    		serviceCIDRSynced: serviceCIDRInformer.Informer().HasSynced,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 13.2K bytes
    - Viewed (0)
Back to top