- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 29 for NodeAddress (0.15 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)