- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 35 for netutils (0.15 sec)
-
pkg/proxy/ipvs/util/ipvs_test.go
Address: netutils.ParseIPSloppy("1.2.3.4"), Port: 3080, }, rsB: &RealServer{ Address: netutils.ParseIPSloppy("1.2.3.4"), Port: 3080, }, equal: true, reason: "All fields equal", }, { rsA: &RealServer{ Address: netutils.ParseIPSloppy("2012::beef"), Port: 3080, }, rsB: &RealServer{ Address: netutils.ParseIPSloppy("2012::beef"),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Dec 19 01:20:51 UTC 2023 - 8K bytes - Viewed (0) -
pkg/registry/core/service/ipallocator/storage/storage_test.go
"k8s.io/kubernetes/pkg/registry/registrytest" netutils "k8s.io/utils/net" ) func newStorage(t *testing.T) (*etcd3testing.EtcdTestServer, ipallocator.Interface, allocator.Interface, storage.Interface, factory.DestroyFunc) { etcdStorage, server := registrytest.NewEtcdStorage(t, "") _, cidr, err := netutils.ParseCIDRSloppy("192.168.1.0/24") if err != nil { t.Fatal(err) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Aug 24 09:23:05 UTC 2023 - 5.9K bytes - Viewed (0) -
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 } // 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) -
pkg/proxy/ipvs/util/testing/fake_test.go
// Add a virtual server vs := &utilipvs.VirtualServer{ Address: netutils.ParseIPSloppy("10.20.30.40"), Port: uint16(80), Protocol: string("TCP"), } rss := []*utilipvs.RealServer{ {Address: netutils.ParseIPSloppy("172.16.2.1"), Port: 8080, Weight: 1}, {Address: netutils.ParseIPSloppy("172.16.2.2"), Port: 8080, Weight: 2}, {Address: netutils.ParseIPSloppy("172.16.2.3"), Port: 8080, Weight: 3}, }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Dec 19 01:20:51 UTC 2023 - 5.6K bytes - Viewed (0) -
pkg/kubelet/certificate/kubelet_test.go
{Type: v1.NodeInternalIP, Address: "3.3.3.3"}, }, wantDNSNames: []string{"hostname-1", "hostname-2", "hostname-3"}, wantIPs: []net.IP{netutils.ParseIPSloppy("1.1.1.1"), netutils.ParseIPSloppy("2.2.2.2"), netutils.ParseIPSloppy("3.3.3.3")}, }, { name: "handle IP and DNS hostnames", addresses: []v1.NodeAddress{ {Type: v1.NodeHostName, Address: "hostname"},
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jun 06 03:07:40 UTC 2024 - 7.4K bytes - Viewed (0) -
cmd/cloud-controller-manager/nodeipamcontroller.go
_, serviceCIDR, err = netutils.ParseCIDRSloppy(nodeIPAMConfig.ServiceCIDR) if err != nil { klog.ErrorS(err, "Unsuccessful parsing of service CIDR", "CIDR", nodeIPAMConfig.ServiceCIDR) } } if len(strings.TrimSpace(nodeIPAMConfig.SecondaryServiceCIDR)) != 0 { _, secondaryServiceCIDR, err = netutils.ParseCIDRSloppy(nodeIPAMConfig.SecondaryServiceCIDR) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Oct 14 19:06:22 UTC 2023 - 8.9K bytes - Viewed (0) -
pkg/proxy/util/endpoints.go
*/ package util import ( "net" "k8s.io/klog/v2" netutils "k8s.io/utils/net" ) // IPPart returns just the IP part of an IP or IP:port or endpoint string. If the IP // part is an IPv6 address enclosed in brackets (e.g. "[fd00:1::5]:9999"), // then the brackets are stripped as well. func IPPart(s string) string { if ip := netutils.ParseIPSloppy(s); ip != nil { // IP address without port return s }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 20 11:57:43 UTC 2024 - 1.3K bytes - Viewed (0) -
cmd/kube-apiserver/app/options/validation.go
serviceIPRange, _, err := controlplaneapiserver.ServiceIPRange(extra.PrimaryServiceClusterIPRange) if err != nil { return []error{fmt.Errorf("error determining service IP ranges: %w", err)} } if netutils.IsIPv4CIDR(&serviceIPRange) != netutils.IsIPv4(generic.AdvertiseAddress) { return []error{fmt.Errorf("service IP family %q must match public address family %q", extra.PrimaryServiceClusterIPRange.String(), generic.AdvertiseAddress.String())} }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Oct 31 21:05:06 UTC 2023 - 6.2K bytes - Viewed (0) -
pkg/proxy/util/nodeport_addresses.go
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 for _, str := range npa.cidrStrings { _, cidr, _ := netutils.ParseCIDRSloppy(str)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 13:25:06 UTC 2024 - 3.6K bytes - Viewed (0) -
pkg/controlplane/apiserver/config_test.go
"k8s.io/kubernetes/pkg/controlplane/apiserver/options" generatedopenapi "k8s.io/kubernetes/pkg/generated/openapi" netutils "k8s.io/utils/net" ) func TestBuildGenericConfig(t *testing.T) { opts := options.NewOptions() s := (&apiserveroptions.SecureServingOptions{ BindAddress: netutils.ParseIPSloppy("127.0.0.1"), }).WithLoopback() ln, err := net.Listen("tcp", "127.0.0.1:0") if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Apr 26 12:14:06 UTC 2024 - 2.5K bytes - Viewed (0)