Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 24 for NodeAddress (0.21 sec)

  1. pkg/kubelet/nodestatus/setters_test.go

    			nodeAddresses:     []v1.NodeAddress{},
    			cloudProviderType: cloudProviderExternal,
    			expectedAddresses: []v1.NodeAddress{
    				{Type: v1.NodeHostName, Address: testKubeletHostname},
    			},
    			shouldError: false,
    		},
    		{
    			name:              "cloud provider is external and no nodeIP",
    			nodeAddresses:     []v1.NodeAddress{},
    			cloudProviderType: cloudProviderExternal,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 25 21:47:24 UTC 2024
    - 76.1K bytes
    - Viewed (0)
  2. pkg/kubelet/certificate/kubelet_test.go

    	tests := []struct {
    		name         string
    		addresses    []v1.NodeAddress
    		wantDNSNames []string
    		wantIPs      []net.IP
    	}{
    		{
    			name:         "empty",
    			addresses:    nil,
    			wantDNSNames: nil,
    			wantIPs:      nil,
    		},
    		{
    			name:         "ignore empty values",
    			addresses:    []v1.NodeAddress{{Type: v1.NodeHostName, Address: ""}},
    			wantDNSNames: nil,
    			wantIPs:      nil,
    		},
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Jun 06 03:07:40 UTC 2024
    - 7.4K bytes
    - Viewed (0)
  3. pkg/kubelet/nodestatus/setters.go

    // Setters may partially mutate the node before returning an error.
    type Setter func(ctx context.Context, node *v1.Node) error
    
    // NodeAddress returns a Setter that updates address-related information on the node.
    func NodeAddress(nodeIPs []net.IP, // typically Kubelet.nodeIPs
    	validateNodeIPFunc func(net.IP) error, // typically Kubelet.nodeIPValidator
    	hostname string, // typically Kubelet.hostname
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 25 12:12:04 UTC 2024
    - 30.5K bytes
    - Viewed (0)
  4. pkg/kubelet/kubelet_node_status_test.go

    		Name   string
    		Before []v1.NodeAddress
    		After  []v1.NodeAddress
    	}{
    		{
    			Name:   "nil to populated",
    			Before: nil,
    			After: []v1.NodeAddress{
    				{Type: v1.NodeInternalIP, Address: "127.0.0.1"},
    				{Type: v1.NodeHostName, Address: testKubeletHostname},
    			},
    		},
    		{
    			Name:   "empty to populated",
    			Before: []v1.NodeAddress{},
    			After: []v1.NodeAddress{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 08 19:23:19 UTC 2024
    - 115.8K bytes
    - Viewed (0)
  5. pkg/kubelet/certificate/kubelet.go

    // or returns an error.
    func NewKubeletServerCertificateManager(kubeClient clientset.Interface, kubeCfg *kubeletconfig.KubeletConfiguration, nodeName types.NodeName, getAddresses func() []v1.NodeAddress, certDirectory string) (certificate.Manager, error) {
    	var clientsetFn certificate.ClientsetFunc
    	if kubeClient != nil {
    		clientsetFn = func(current *tls.Certificate) (clientset.Interface, error) {
    			return kubeClient, nil
    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. pkg/kubelet/kubelet_node_status.go

    		}
    	}
    }
    
    func (kl *Kubelet) setLastObservedNodeAddresses(addresses []v1.NodeAddress) {
    	kl.lastObservedNodeAddressesMux.Lock()
    	defer kl.lastObservedNodeAddressesMux.Unlock()
    	kl.lastObservedNodeAddresses = addresses
    }
    func (kl *Kubelet) getLastObservedNodeAddresses() []v1.NodeAddress {
    	kl.lastObservedNodeAddressesMux.RLock()
    	defer kl.lastObservedNodeAddressesMux.RUnlock()
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 31.1K bytes
    - Viewed (0)
  7. pkg/kubelet/kubelet_pods_test.go

    }
    
    func TestGenerateAPIPodStatusHostNetworkPodIPs(t *testing.T) {
    	testcases := []struct {
    		name          string
    		nodeAddresses []v1.NodeAddress
    		criPodIPs     []string
    		podIPs        []v1.PodIP
    	}{
    		{
    			name: "Simple",
    			nodeAddresses: []v1.NodeAddress{
    				{Type: v1.NodeInternalIP, Address: "10.0.0.1"},
    			},
    			podIPs: []v1.PodIP{
    				{IP: "10.0.0.1"},
    			},
    		},
    		{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 07 00:05:23 UTC 2024
    - 198.8K bytes
    - Viewed (0)
  8. cmd/kube-proxy/app/server_test.go

    	node := &v1.Node{
    		ObjectMeta: metav1.ObjectMeta{
    			Name: name,
    		},
    		Status: v1.NodeStatus{
    			Addresses: []v1.NodeAddress{},
    		},
    	}
    
    	if primaryIP != "" {
    		node.Status.Addresses = append(node.Status.Addresses,
    			v1.NodeAddress{Type: v1.NodeInternalIP, Address: primaryIP},
    		)
    	}
    
    	return node
    }
    
    // Test that getNodeIPs retries on failure
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Apr 22 05:08:41 UTC 2024
    - 32.3K bytes
    - Viewed (0)
  9. pkg/printers/internalversion/printers_test.go

    	}{
    		{
    			node: api.Node{
    				ObjectMeta: metav1.ObjectMeta{Name: "foo1"},
    				Status: api.NodeStatus{
    					NodeInfo:  api.NodeSystemInfo{OSImage: "fake-os-image"},
    					Addresses: []api.NodeAddress{{Type: api.NodeExternalIP, Address: "1.1.1.1"}},
    				},
    			},
    			// Columns: Name, Status, Roles, Age, KubeletVersion, NodeInternalIP, NodeExternalIP, OSImage, KernelVersion, ContainerRuntimeVersion
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 11 14:04:15 UTC 2024
    - 218.6K bytes
    - Viewed (0)
  10. pkg/apis/core/v1/zz_generated.conversion.go

    		return err
    	}
    	if err := s.AddGeneratedConversionFunc((*v1.NodeAddress)(nil), (*core.NodeAddress)(nil), func(a, b interface{}, scope conversion.Scope) error {
    		return Convert_v1_NodeAddress_To_core_NodeAddress(a.(*v1.NodeAddress), b.(*core.NodeAddress), scope)
    	}); err != nil {
    		return err
    	}
    	if err := s.AddGeneratedConversionFunc((*core.NodeAddress)(nil), (*v1.NodeAddress)(nil), func(a, b interface{}, scope conversion.Scope) error {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 29 22:40:29 UTC 2024
    - 472.1K bytes
    - Viewed (0)
Back to top