Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 29 for NodeAddress (0.16 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. pilot/pkg/config/kube/ingress/status_test.go

    					Hostname: hostname,
    				}},
    			},
    		},
    	},
    	&corev1.Node{
    		ObjectMeta: metav1.ObjectMeta{
    			Name: "foo_node",
    		},
    		Status: corev1.NodeStatus{
    			Addresses: []corev1.NodeAddress{
    				{
    					Type:    corev1.NodeExternalIP,
    					Address: nodeIP,
    				},
    			},
    		},
    	},
    }
    
    func fakeMeshHolder(ingressService string) mesh.Watcher {
    	config := mesh.DefaultMeshConfig()
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Feb 28 16:41:38 UTC 2024
    - 5.8K bytes
    - Viewed (0)
  7. 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)
  8. 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)
  9. pilot/pkg/xds/mesh_network_test.go

    					ExternalIPs: []string{"3.3.3.3"},
    				},
    			}},
    		},
    		corev1.ServiceTypeNodePort: {
    			"cluster-1": {
    				&corev1.Node{Status: corev1.NodeStatus{Addresses: []corev1.NodeAddress{{Type: corev1.NodeExternalIP, Address: "2.2.2.2"}}}},
    				&corev1.Service{
    					ObjectMeta: metav1.ObjectMeta{
    						Name:        "istio-ingressgateway",
    						Namespace:   "istio-system",
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Mar 27 16:59:05 UTC 2024
    - 24.6K bytes
    - Viewed (0)
  10. 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)
Back to top