- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 71 for ParseIPSloppy (0.43 sec)
-
cmd/kube-proxy/app/server_linux_test.go
s := &ProxyServer{ Config: tt.config, Client: client, Hostname: "nodename", NodeIPs: map[v1.IPFamily]net.IP{ v1.IPv4Protocol: netutils.ParseIPSloppy("127.0.0.1"), v1.IPv6Protocol: net.IPv6zero, }, } err := s.platformSetup(ctx) if err != nil { t.Errorf("ProxyServer.createProxier() error = %v", err) return }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Apr 28 15:51:23 UTC 2024 - 21.9K bytes - Viewed (0) -
cmd/kubeadm/app/util/config/initconfiguration.go
func SetAPIEndpointDynamicDefaults(cfg *kubeadmapi.APIEndpoint) error { // validate cfg.API.AdvertiseAddress. addressIP := netutils.ParseIPSloppy(cfg.AdvertiseAddress) if addressIP == nil && cfg.AdvertiseAddress != "" { return errors.Errorf("couldn't use \"%s\" as \"apiserver-advertise-address\", must be ipv4 or ipv6 address", cfg.AdvertiseAddress) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jan 05 12:41:16 UTC 2024 - 17.3K bytes - Viewed (0) -
pkg/proxy/ipvs/proxier.go
// from documentation is not unheard of, so the restriction to not use the TEST-NET-2 range // must be documented. vs := utilipvs.VirtualServer{ Address: netutils.ParseIPSloppy("198.51.100.0"), Protocol: "TCP", Port: 20000, Scheduler: scheduler, } if err := ipvs.AddVirtualServer(&vs); err != nil { logger.Error(err, "Could not create dummy VS", "scheduler", scheduler)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Apr 28 15:51:23 UTC 2024 - 77.7K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/options/serving.go
// <host>_<ip>-<ip>_<alternateDNS>-<alternateDNS>.key FixtureDirectory string } func NewSecureServingOptions() *SecureServingOptions { return &SecureServingOptions{ BindAddress: netutils.ParseIPSloppy("0.0.0.0"), BindPort: 443, ServerCert: GeneratableKeyCert{ PairName: "apiserver", CertDirectory: "apiserver.local.config/certificates", }, } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Apr 27 13:08:18 UTC 2024 - 15.9K bytes - Viewed (0) -
pkg/registry/core/service/storage/alloc.go
} if err != nil { return allocated, errors.NewInternalError(fmt.Errorf("failed to allocate a serviceIP: %v", err)) } allocated[family] = allocatedIP.String() } else { parsedIP := netutils.ParseIPSloppy(ip) if parsedIP == nil { return allocated, errors.NewInternalError(fmt.Errorf("failed to parse service IP %q", ip)) } var err error
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Oct 31 21:05:05 UTC 2023 - 37.3K bytes - Viewed (0) -
cmd/kubeadm/app/preflight/checks.go
} if !isSecondaryControlPlane { checks = addCommonChecks(execer, cfg.KubernetesVersion, &cfg.NodeRegistration, checks) // Check if Bridge-netfilter and IPv6 relevant flags are set if ip := netutils.ParseIPSloppy(cfg.LocalAPIEndpoint.AdvertiseAddress); ip != nil { if !IPV4Check && netutils.IsIPv4(ip) { IPV4Check = true } if !IPV6Check && netutils.IsIPv6(ip) { IPV6Check = true } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jun 03 11:20:55 UTC 2024 - 39.5K bytes - Viewed (0) -
pkg/registry/core/service/ipallocator/ipallocator.go
}).AsSelectorPreValidated() ips, err := a.ipAddressLister.List(ipLabelSelector) if err != nil { return } for _, ip := range ips { f(netutils.ParseIPSloppy(ip.Name)) } } func (a *Allocator) CIDR() net.IPNet { return *a.cidr } // for testing func (a *Allocator) Has(ip net.IP) bool { // convert IP to name name := ip.String()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Oct 31 21:05:04 UTC 2023 - 17K bytes - Viewed (0) -
pkg/proxy/iptables/proxier_test.go
&net.IPNet{IP: netutils.ParseIPSloppy(testExternalIP), Mask: net.CIDRMask(24, 32)}, &net.IPNet{IP: netutils.ParseIPSloppy(testNodeIPv6), Mask: net.CIDRMask(64, 128)}, &net.IPNet{IP: netutils.ParseIPSloppy(testNodeIPv6Alt), Mask: net.CIDRMask(64, 128)}, } networkInterfacer.AddInterfaceAddr(&itf1, addrs1) p := &Proxier{ ipFamily: ipfamily,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 21 14:39:54 UTC 2024 - 249.9K bytes - Viewed (0) -
cmd/kube-proxy/app/server.go
// non-zero IP of wrongFamily. func badBindAddress(bindAddress string, wrongFamily netutils.IPFamily) bool { if host, _, _ := net.SplitHostPort(bindAddress); host != "" { ip := netutils.ParseIPSloppy(host) if ip != nil && netutils.IPFamilyOf(ip) == wrongFamily && !ip.IsUnspecified() { return true } } return false }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Apr 26 13:27:41 UTC 2024 - 46.8K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/genericapiserver_test.go
func setUp(t *testing.T) (Config, *assert.Assertions) { config := NewConfig(codecs) config.ExternalAddress = "192.168.10.4:443" config.PublicAddress = netutils.ParseIPSloppy("192.168.10.4") config.LegacyAPIGroupPrefixes = sets.NewString("/api") config.LoopbackClientConfig = &restclient.Config{} clientset := fake.NewSimpleClientset() if clientset == nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 29 18:59:21 UTC 2024 - 23.2K bytes - Viewed (0)