Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 46 for IPv4Protocol (0.47 sec)

  1. cmd/kube-proxy/app/server.go

    func detectNodeIPs(ctx context.Context, rawNodeIPs []net.IP, bindAddress string) (v1.IPFamily, map[v1.IPFamily]net.IP) {
    	logger := klog.FromContext(ctx)
    	primaryFamily := v1.IPv4Protocol
    	nodeIPs := map[v1.IPFamily]net.IP{
    		v1.IPv4Protocol: net.IPv4(127, 0, 0, 1),
    		v1.IPv6Protocol: net.IPv6loopback,
    	}
    
    	if len(rawNodeIPs) > 0 {
    		if !netutils.IsIPv4(rawNodeIPs[0]) {
    			primaryFamily = v1.IPv6Protocol
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Apr 26 13:27:41 UTC 2024
    - 46.8K bytes
    - Viewed (0)
  2. pkg/registry/core/service/storage/storage.go

    }
    
    // otherFamily returns the non-selected IPFamily.  This assumes the input is
    // valid.
    func otherFamily(fam api.IPFamily) api.IPFamily {
    	if fam == api.IPv4Protocol {
    		return api.IPv6Protocol
    	}
    	return api.IPv4Protocol
    }
    
    var (
    	_ rest.ShortNamesProvider = &REST{}
    	_ rest.CategoriesProvider = &REST{}
    )
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 11 13:09:33 UTC 2024
    - 22.3K bytes
    - Viewed (0)
  3. pkg/registry/core/service/ipallocator/bitmap_test.go

    		free             int
    		released         string
    		outOfRange       []string
    		alreadyAllocated string
    	}{
    		{
    			name:     "IPv4",
    			cidr:     "192.168.1.0/24",
    			family:   api.IPv4Protocol,
    			free:     254,
    			released: "192.168.1.5",
    			outOfRange: []string{
    				"192.168.0.1",   // not in 192.168.1.0/24
    				"192.168.1.0",   // reserved (base address)
    				"192.168.1.255", // reserved (broadcast address)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jan 25 20:32:40 UTC 2023
    - 21.1K bytes
    - Viewed (0)
  4. pkg/registry/core/service/ipallocator/controller/repairip.go

    			}
    		}
    	}
    	r.muTree.Lock()
    	defer r.muTree.Unlock()
    	r.tree = tree
    	return nil
    }
    
    func newIPAddress(name string, svc *v1.Service) *networkingv1alpha1.IPAddress {
    	family := string(v1.IPv4Protocol)
    	if netutils.IsIPv6String(name) {
    		family = string(v1.IPv6Protocol)
    	}
    	return &networkingv1alpha1.IPAddress{
    		ObjectMeta: metav1.ObjectMeta{
    			Name: name,
    			Labels: map[string]string{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 24.7K bytes
    - Viewed (0)
  5. pkg/proxy/conntrack/cleanup_test.go

    	// provide our own implementation of that interface, or else use a
    	// proxy.ServiceChangeTracker to construct them and fill in the map for us.
    
    	sct := proxy.NewServiceChangeTracker(nil, v1.IPv4Protocol, nil, nil)
    	svc := &v1.Service{
    		ObjectMeta: metav1.ObjectMeta{
    			Name:      "cleanup-test",
    			Namespace: "test",
    		},
    		Spec: v1.ServiceSpec{
    			ClusterIP:   testClusterIP,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Jan 15 18:09:05 UTC 2024
    - 7.6K bytes
    - Viewed (0)
  6. pkg/apis/core/validation/validation_test.go

    				s.Spec.IPFamilies = []core.IPFamily{core.IPv4Protocol, core.IPv6Protocol}
    			},
    			numErrs: 0,
    		},
    
    		{
    			name: "invalid, service with 2+ ipFamilies",
    			tweakSvc: func(s *core.Service) {
    				s.Spec.IPFamilyPolicy = &requireDualStack
    				s.Spec.IPFamilies = []core.IPFamily{core.IPv4Protocol, core.IPv6Protocol, core.IPv4Protocol}
    			},
    			numErrs: 1,
    		}, {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 29 22:40:29 UTC 2024
    - 857.7K bytes
    - Viewed (0)
  7. pkg/proxy/nftables/proxier.go

    	initOnly bool,
    ) (proxy.Provider, error) {
    	// Create an ipv4 instance of the single-stack proxier
    	ipv4Proxier, err := NewProxier(ctx, v1.IPv4Protocol,
    		syncPeriod, minSyncPeriod, masqueradeAll, masqueradeBit,
    		localDetectors[v1.IPv4Protocol], hostname, nodeIPs[v1.IPv4Protocol],
    		recorder, healthzServer, nodePortAddresses, initOnly)
    	if err != nil {
    		return nil, fmt.Errorf("unable to create ipv4 proxier: %v", err)
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Jun 08 13:48:54 UTC 2024
    - 55.5K bytes
    - Viewed (0)
  8. pkg/apis/discovery/types.go

    }
    
    // AddressType represents the type of address referred to by an endpoint.
    type AddressType string
    
    const (
    	// AddressTypeIPv4 represents an IPv4 Address.
    	AddressTypeIPv4 = AddressType(api.IPv4Protocol)
    	// AddressTypeIPv6 represents an IPv6 Address.
    	AddressTypeIPv6 = AddressType(api.IPv6Protocol)
    	// AddressTypeFQDN represents a FQDN.
    	AddressTypeFQDN = AddressType("FQDN")
    )
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Oct 16 21:38:06 UTC 2023
    - 7.5K bytes
    - Viewed (0)
  9. pkg/registry/core/service/ipallocator/ipallocator.go

    	}
    
    	// TODO: use the utils/net function once is available
    	size := hostsPerNetwork(cidr)
    	var family api.IPFamily
    	if netutils.IsIPv6CIDR(cidr) {
    		family = api.IPv6Protocol
    	} else {
    		family = api.IPv4Protocol
    	}
    	// Caching the first, offset and last addresses allows to optimize
    	// the search loops by using the netip.Addr iterator instead
    	// of having to do conversions with IP addresses.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Oct 31 21:05:04 UTC 2023
    - 17K bytes
    - Viewed (0)
  10. pkg/controller/endpoint/endpoints_controller_test.go

    var oldTriggerTimeString = triggerTime.Add(-time.Hour).Format(time.RFC3339Nano)
    
    var ipv4only = []v1.IPFamily{v1.IPv4Protocol}
    var ipv6only = []v1.IPFamily{v1.IPv6Protocol}
    var ipv4ipv6 = []v1.IPFamily{v1.IPv4Protocol, v1.IPv6Protocol}
    var ipv6ipv4 = []v1.IPFamily{v1.IPv6Protocol, v1.IPv4Protocol}
    
    func testPod(namespace string, id int, nPorts int, isReady bool, ipFamilies []v1.IPFamily) *v1.Pod {
    	p := &v1.Pod{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Feb 26 06:51:56 UTC 2024
    - 87.7K bytes
    - Viewed (0)
Back to top