- Sort Score
- Result 10 results
- Languages All
Results 71 - 80 of 871 for mynodename (0.11 sec)
-
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) -
staging/src/k8s.io/apiserver/pkg/storage/testing/watcher_tests.go
return nil, fields.Set{ "spec.nodeName": pod.Spec.NodeName, "metadata.name": pod.ObjectMeta.Name, "metadata.namespace": pod.ObjectMeta.Namespace, }, nil } func clusterScopedNodeNameAttrFunc(obj runtime.Object) (labels.Set, fields.Set, error) { pod := obj.(*example.Pod) return nil, fields.Set{ "spec.nodeName": pod.Spec.NodeName, "metadata.name": pod.ObjectMeta.Name, }, nil
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 63.8K bytes - Viewed (0) -
cmd/kubeadm/app/util/apiclient/wait.go
} // getStaticPodSingleHash computes hashes for a single Static Pod resource func getStaticPodSingleHash(client clientset.Interface, nodeName string, component string) (string, error) { staticPodName := fmt.Sprintf("%s-%s", component, nodeName)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Jun 01 07:10:31 UTC 2024 - 13.3K bytes - Viewed (0) -
cmd/kubeadm/app/phases/etcd/local.go
func CreateLocalEtcdStaticPodManifestFile(manifestDir, patchesDir string, nodeName string, cfg *kubeadmapi.ClusterConfiguration, endpoint *kubeadmapi.APIEndpoint, isDryRun bool) error { if cfg.Etcd.External != nil { return errors.New("etcd static pod manifest cannot be generated for cluster using external etcd") } if err := prepareAndWriteEtcdStaticPod(manifestDir, patchesDir, cfg, endpoint, nodeName, []etcdutil.Member{}, isDryRun); err != nil { return err }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Apr 23 14:07:27 UTC 2024 - 13.8K bytes - Viewed (1) -
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) -
pkg/volume/util/operationexecutor/operation_executor_test.go
pdName := "pd-volume" // Act for i := range volumesToAttach { volumesToAttach[i] = VolumeToAttach{ VolumeName: v1.UniqueVolumeName(pdName), NodeName: types.NodeName(fmt.Sprintf("node%d", i)), VolumeSpec: &volume.Spec{ PersistentVolume: &v1.PersistentVolume{ Spec: v1.PersistentVolumeSpec{ AccessModes: []v1.PersistentVolumeAccessMode{v1.ReadWriteOnce},
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 26.9K 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)