- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 89 for netutils (0.45 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)