Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 95 for ParseIPSloppy (0.3 sec)

  1. pkg/kubeapiserver/options/serving.go

    // "normal" API servers running on the platform
    func NewSecureServingOptions() *genericoptions.SecureServingOptionsWithLoopback {
    	o := genericoptions.SecureServingOptions{
    		BindAddress: netutils.ParseIPSloppy("0.0.0.0"),
    		BindPort:    6443,
    		Required:    true,
    		ServerCert: genericoptions.GeneratableKeyCert{
    			PairName:      "apiserver",
    			CertDirectory: "/var/run/kubernetes",
    		},
    	}
    	return o.WithLoopback()
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Aug 20 08:42:09 UTC 2021
    - 1.3K bytes
    - Viewed (0)
  2. pkg/kubeapiserver/options/options.go

    var DefaultServiceNodePortRange = utilnet.PortRange{Base: 30000, Size: 2768}
    
    // DefaultServiceIPCIDR is a CIDR notation of IP range from which to allocate service cluster IPs
    var DefaultServiceIPCIDR = net.IPNet{IP: netutils.ParseIPSloppy("10.0.0.0"), Mask: net.CIDRMask(24, 32)}
    
    // DefaultEtcdPathPrefix is the default key prefix of etcd for API Server
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Aug 20 08:42:09 UTC 2021
    - 1.1K bytes
    - Viewed (0)
  3. pkg/util/flag/flags.go

    	// Attempt to parse into IP first.
    	if netutils.ParseIPSloppy(s) != nil {
    		*v.Val = s
    		return nil
    	}
    
    	// Can not parse into IP, now assume IP:port.
    	host, port, err := net.SplitHostPort(s)
    	if err != nil {
    		return fmt.Errorf("%q is not in a valid format (ip or ip:port): %v", s, err)
    	}
    	if netutils.ParseIPSloppy(host) == nil {
    		return fmt.Errorf("%q is not a valid IP address", host)
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jul 19 03:30:46 UTC 2022
    - 7.8K bytes
    - Viewed (0)
  4. pkg/controlplane/reconcilers/lease_test.go

    				r.StopReconciling()
    				err = r.RemoveEndpoints(test.serviceName, netutils.ParseIPSloppy(test.ip), test.endpointPorts)
    				if err != nil {
    					t.Errorf("unexpected error remove endpoints: %v", err)
    				}
    
    				// reconcile endpoints in another goroutine
    				err = r.ReconcileEndpoints(test.serviceName, netutils.ParseIPSloppy(test.ip), test.endpointPorts, false)
    				if err != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Aug 24 09:23:05 UTC 2023
    - 28.7K bytes
    - Viewed (0)
  5. pkg/kubelet/certificate/kubelet.go

    			continue
    		}
    
    		switch address.Type {
    		case v1.NodeHostName:
    			if ip := netutils.ParseIPSloppy(address.Address); ip != nil {
    				seenIPs[address.Address] = true
    			} else {
    				seenDNSNames[address.Address] = true
    			}
    		case v1.NodeExternalIP, v1.NodeInternalIP:
    			if ip := netutils.ParseIPSloppy(address.Address); ip != nil {
    				seenIPs[address.Address] = true
    			}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Jun 06 03:07:16 UTC 2024
    - 10.3K bytes
    - Viewed (0)
  6. cmd/kubeadm/app/apis/kubeadm/apiendpoint.go

    	apiEndpointHost, apiEndpointPortStr, err := net.SplitHostPort(apiEndpoint)
    	if err != nil {
    		return APIEndpoint{}, errors.Wrapf(err, "invalid advertise address endpoint: %s", apiEndpoint)
    	}
    	if netutils.ParseIPSloppy(apiEndpointHost) == nil {
    		return APIEndpoint{}, errors.Errorf("invalid API endpoint IP: %s", apiEndpointHost)
    	}
    	apiEndpointPort, err := net.LookupPort("tcp", apiEndpointPortStr)
    	if err != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Aug 20 08:42:09 UTC 2021
    - 1.6K bytes
    - Viewed (0)
  7. staging/src/k8s.io/apiserver/pkg/server/options/serving_with_loopback_test.go

    )
    
    func TestEmptyMainCert(t *testing.T) {
    	secureServingInfo := &server.SecureServingInfo{}
    	var loopbackClientConfig *rest.Config
    
    	s := (&SecureServingOptions{
    		BindAddress: netutils.ParseIPSloppy("127.0.0.1"),
    	}).WithLoopback()
    	ln, err := net.Listen("tcp", "127.0.0.1:0")
    	if err != nil {
    		t.Fatalf("failed to listen on 127.0.0.1:0")
    	}
    	defer ln.Close()
    	s.Listener = ln
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Aug 20 08:42:09 UTC 2021
    - 1.4K bytes
    - Viewed (0)
  8. pkg/controlplane/reconcilers/instancecount_test.go

    			reconciler := NewMasterCountEndpointReconciler(test.additionalMasters+1, epAdapter)
    			err := reconciler.ReconcileEndpoints(test.serviceName, netutils.ParseIPSloppy(test.ip), test.endpointPorts, true)
    			if err != nil {
    				t.Errorf("unexpected error reconciling: %v", err)
    			}
    
    			err = verifyCreatesAndUpdates(fakeClient, test.expectCreate, test.expectUpdate)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 27 12:46:24 UTC 2022
    - 14K bytes
    - Viewed (0)
  9. pkg/util/node/node.go

    	for _, addr := range node.Status.Addresses {
    		if addr.Type == v1.NodeInternalIP {
    			ip := netutils.ParseIPSloppy(addr.Address)
    			if ip != nil {
    				allIPs = append(allIPs, ip)
    			}
    		}
    	}
    	for _, addr := range node.Status.Addresses {
    		if addr.Type == v1.NodeExternalIP {
    			ip := netutils.ParseIPSloppy(addr.Address)
    			if ip != nil {
    				allIPs = append(allIPs, ip)
    			}
    		}
    	}
    	if len(allIPs) == 0 {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jan 27 23:24:38 UTC 2023
    - 4.8K bytes
    - Viewed (0)
  10. pkg/controlplane/apiserver/config_test.go

    	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 {
    		t.Fatalf("failed to listen on 127.0.0.1:0")
    	}
    	defer ln.Close()
    	s.Listener = ln
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Apr 26 12:14:06 UTC 2024
    - 2.5K bytes
    - Viewed (0)
Back to top