Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for NodeAddress (0.21 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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