- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 345 for NodeName (0.16 sec)
-
pkg/kubelet/pod/mirror_client.go
apiserverClient clientset.Interface nodeGetter nodeGetter nodeName string } // NewBasicMirrorClient returns a new MirrorClient. func NewBasicMirrorClient(apiserverClient clientset.Interface, nodeName string, nodeGetter nodeGetter) MirrorClient { return &basicMirrorClient{ apiserverClient: apiserverClient, nodeName: nodeName, nodeGetter: nodeGetter, } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jun 21 11:38:40 UTC 2021 - 5.5K bytes - Viewed (0) -
cni/pkg/repair/repair_test_helpers.go
Namespace: "default", Labels: args.Labels, Annotations: args.Annotations, }, Spec: corev1.PodSpec{ NodeName: args.NodeName, Volumes: nil, InitContainers: []corev1.Container{ { Name: args.InitContainerName, }, }, Containers: []corev1.Container{ { Name: "payload-container", }, }, }, Status: corev1.PodStatus{
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri May 12 17:39:53 UTC 2023 - 4.7K bytes - Viewed (0) -
pkg/controller/daemon/util/daemonset_util.go
// GetTargetNodeName get the target node name of DaemonSet pods. If `.spec.NodeName` is not empty (nil), // return `.spec.NodeName`; otherwise, retrieve node name of pending pods from NodeAffinity. Return error // if failed to retrieve node name from `.spec.NodeName` and NodeAffinity. func GetTargetNodeName(pod *v1.Pod) (string, error) { if len(pod.Spec.NodeName) != 0 { return pod.Spec.NodeName, nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jul 18 11:54:59 UTC 2022 - 9.3K bytes - Viewed (0) -
pkg/kube/kclient/index_test.go
if len(pod.Spec.NodeName) == 0 { return nil } if len(pod.Spec.ServiceAccountName) == 0 { return nil } return []SaNode{{ ServiceAccount: types.NamespacedName{ Namespace: pod.Namespace, Name: pod.Spec.ServiceAccountName, }, Node: pod.Spec.NodeName, }} }) k1 := SaNode{ ServiceAccount: types.NamespacedName{
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 04 03:49:30 UTC 2023 - 5.7K bytes - Viewed (0) -
pkg/registry/discovery/endpointslice/strategy.go
newTopologyNodeName, ok := ep.DeprecatedTopology[corev1.LabelHostname] if ep.NodeName == nil && ok && prevNodeNames.Has(newTopologyNodeName) && len(apivalidation.ValidateNodeName(newTopologyNodeName, false)) == 0 { // Copy the label previously used to store the node name into the nodeName field, // in order to make partial updates preserve previous node info ep.NodeName = &newTopologyNodeName }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jan 02 10:00:01 UTC 2023 - 7.6K bytes - Viewed (0) -
cmd/kubeadm/app/phases/kubelet/flags_test.go
}, } for _, tc := range testCases { t.Run(tc.name, func(t *testing.T) { nodeName, hostname, err := GetNodeNameAndHostname(tc.opts.nodeRegOpts) if err != nil { t.Errorf("unexpected error: %v", err) } if nodeName != tc.expectedNodeName { t.Errorf("expected nodeName: %v, got %v", tc.expectedNodeName, nodeName) } if hostname != tc.expectedHostName {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 24 07:02:51 UTC 2024 - 4.9K bytes - Viewed (0) -
platforms/core-configuration/file-collections/src/main/java/org/gradle/api/internal/file/AntFileSetBuilder.java
@Override public Object addToAntBuilder(final Object node, String nodeName) { final DynamicObject dynamicObject = new BeanDynamicObject(node); for (final DirectoryTree tree : trees) { if (!tree.getDir().exists()) { continue; }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Sep 28 09:51:04 UTC 2023 - 1.8K bytes - Viewed (0) -
cmd/http-tracer.go
for k, v := range reqHeaders { inputBytes += len(k) + len(v) } // Calculate node name nodeName := r.Host if globalIsDistErasure { nodeName = globalLocalNodeName } if host, port, err := net.SplitHostPort(nodeName); err == nil { if port == "443" || port == "80" { nodeName = host } } // Calculate reqPath reqPath := r.URL.RawPath if reqPath == "" {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 03 15:45:54 UTC 2024 - 6K bytes - Viewed (0) -
cmd/kubeadm/app/phases/markcontrolplane/markcontrolplane_test.go
}, } for _, tc := range tests { t.Run(tc.name, func(t *testing.T) { nodename := "node01" controlPlaneNode := &v1.Node{ ObjectMeta: metav1.ObjectMeta{ Name: nodename, Labels: map[string]string{ v1.LabelHostname: nodename, }, }, } for _, label := range tc.existingLabels { controlPlaneNode.ObjectMeta.Labels[label] = ""
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Aug 25 14:22:20 UTC 2022 - 5K bytes - Viewed (0) -
pkg/controller/volume/attachdetach/metrics/metrics_test.go
nodeName := k8stypes.NodeName("node-name") dsw.AddNode(nodeName) _, err := dsw.AddPod(types.UniquePodName(podName), controllervolumetesting.NewPod(podName, podName), volumeSpec, nodeName) if err != nil { t.Fatalf("Expected no error, got %v", err) } logger, _ := ktesting.NewTestContext(t) asw.AddVolumeNode(logger, volumeName, volumeSpec, nodeName, "", true)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 01 10:42:15 UTC 2024 - 6.1K bytes - Viewed (0)