Search Options

Results per page
Sort
Preferred Languages
Advance

Results 51 - 60 of 71 for ParseIPSloppy (0.43 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top