Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 92 for netutils (0.16 sec)

  1. pkg/proxy/ipvs/graceful_termination_test.go

    	}{
    		{
    			name: "graceful delete, no connections results in deleting the real server immediatetly",
    			vs: &utilipvs.VirtualServer{
    				Address:  netutils.ParseIPSloppy("1.1.1.1"),
    				Protocol: "tcp",
    				Port:     uint16(80),
    			},
    			rs: &utilipvs.RealServer{
    				Address:      netutils.ParseIPSloppy("10.0.0.1"),
    				Port:         uint16(80),
    				Weight:       100,
    				ActiveConn:   0,
    				InactiveConn: 0,
    			},
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Dec 19 01:20:51 UTC 2023
    - 11K bytes
    - Viewed (0)
  2. 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)
  3. pkg/registry/core/service/ipallocator/bitmap_test.go

    			if err := r.Release(released); err != nil {
    				t.Fatal(err)
    			}
    			for _, outOfRange := range tc.outOfRange {
    				err = r.Allocate(netutils.ParseIPSloppy(outOfRange))
    				if _, ok := err.(*ErrNotInRange); !ok {
    					t.Fatal(err)
    				}
    			}
    			if err := r.Allocate(netutils.ParseIPSloppy(tc.alreadyAllocated)); err != ErrAllocated {
    				t.Fatal(err)
    			}
    			if f := r.Free(); f != 1 {
    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. staging/src/k8s.io/apiserver/pkg/server/options/server_run_options_test.go

    	utilerrors "k8s.io/apimachinery/pkg/util/errors"
    	netutils "k8s.io/utils/net"
    )
    
    func TestServerRunOptionsValidate(t *testing.T) {
    	testCases := []struct {
    		name        string
    		testOptions *ServerRunOptions
    		expectErr   string
    	}{
    		{
    			name: "Test when MaxRequestsInFlight is negative value",
    			testOptions: &ServerRunOptions{
    				AdvertiseAddress:            netutils.ParseIPSloppy("192.168.10.10"),
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Feb 27 15:49:49 UTC 2023
    - 10.9K bytes
    - Viewed (0)
  5. pkg/proxy/ipvs/util/ipvs_linux_test.go

    				Weight:          1,
    				Address:         netutils.ParseIPSloppy("1.2.3.4"),
    			},
    			RealServer{
    				Address: netutils.ParseIPSloppy("1.2.3.4"),
    				Port:    54321,
    				Weight:  1,
    			},
    		},
    		{
    			libipvs.Destination{
    				Port:            53,
    				ConnectionFlags: 0,
    				Weight:          1,
    				Address:         netutils.ParseIPSloppy("2002::cafe"),
    			},
    			RealServer{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 27 16:37:50 UTC 2023
    - 9.9K bytes
    - Viewed (0)
  6. 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)
  7. pkg/registry/core/service/ipallocator/cidrallocator_test.go

    		allocator, err := r.getAllocator(netutils.ParseIPSloppy("10.0.0.11"))
    		if err != nil {
    			return false, nil
    		}
    		allocator.ipAddressSynced = func() bool { return true }
    		return allocator.ready.Load(), nil
    	})
    	if err != nil {
    		t.Fatal(err)
    	}
    	// allocate one IP from the new allocator
    	err = r.Allocate(netutils.ParseIPSloppy("10.0.0.11"))
    	if err != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Oct 31 21:05:06 UTC 2023
    - 13.7K bytes
    - Viewed (0)
  8. pkg/registry/core/service/ipallocator/ipallocator_test.go

    			if err := r.Release(released); err != nil {
    				t.Fatal(err)
    			}
    			for _, outOfRange := range tc.outOfRange {
    				err = r.Allocate(netutils.ParseIPSloppy(outOfRange))
    				if err == nil {
    					t.Fatalf("unexpacted allocating of %s", outOfRange)
    				}
    			}
    			if err := r.Allocate(netutils.ParseIPSloppy(tc.alreadyAllocated)); err == nil {
    				t.Fatalf("unexpected allocation of %s", tc.alreadyAllocated)
    			}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sun Jun 25 13:14:46 UTC 2023
    - 24.2K bytes
    - Viewed (0)
  9. 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)
  10. pkg/registry/core/service/ipallocator/controller/repair_test.go

    	}
    }
    
    func TestRepairLeakDualStack(t *testing.T) {
    	clearMetrics()
    	_, cidr, _ := netutils.ParseCIDRSloppy("192.168.1.0/24")
    	previous, err := ipallocator.NewInMemory(cidr)
    	if err != nil {
    		t.Fatal(err)
    	}
    
    	previous.Allocate(netutils.ParseIPSloppy("192.168.1.10"))
    
    	_, secondaryCIDR, _ := netutils.ParseCIDRSloppy("2000::/108")
    	secondaryPrevious, err := ipallocator.NewInMemory(secondaryCIDR)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Sep 30 15:46:06 UTC 2023
    - 21.1K bytes
    - Viewed (0)
Back to top