- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 284 for NodeName (0.17 sec)
-
pkg/scheduler/internal/cache/cache.go
} if currState.pod.Spec.NodeName != pod.Spec.NodeName { logger.Error(nil, "Pod was added to a different node than it was assumed", "podKey", key, "pod", klog.KObj(pod), "assumedNode", klog.KRef("", pod.Spec.NodeName), "currentNode", klog.KRef("", currState.pod.Spec.NodeName)) if pod.Spec.NodeName != "" { // An empty NodeName is possible when the scheduler misses a Delete
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Oct 24 09:56:48 UTC 2023 - 24.9K bytes - Viewed (0) -
pkg/volume/testing/volume_host.go
host := &fakeVolumeHost{rootDir: rootDir, kubeClient: kubeClient, nodeName: nodeName, csiDriverLister: driverLister, volumeAttachmentLister: volumeAttachLister} host.mounter = mount.NewFakeMounter(nil) host.hostUtil = hostutil.NewFakeHostUtil(pathToTypeMap)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 11 09:02:45 UTC 2024 - 16.5K bytes - Viewed (0) -
cmd/kubeadm/app/cmd/upgrade/plan.go
func newComponentUpgradePlan(name, currentVersion, newVersion, nodeName string) outputapiv1alpha3.ComponentUpgradePlan { return outputapiv1alpha3.ComponentUpgradePlan{ Name: name, CurrentVersion: currentVersion, NewVersion: newVersion, NodeName: nodeName, } } // runPlan takes care of outputting available versions to upgrade to for the user
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Mar 03 03:03:29 UTC 2024 - 14.9K bytes - Viewed (0) -
pkg/controller/volume/attachdetach/util/util_test.go
migratedVolume = "migrated-volume-name" nonMigratedVolume = "non-migrated-volume-name" testNodeName = "test-node-name" ) var ( dirOrCreate = v1.HostPathType(v1.HostPathDirectoryOrCreate) nodeName = kubetypes.NodeName(testNodeName) hostPath = &v1.HostPathVolumeSource{ Path: socketPath, Type: &dirOrCreate, } migratedObjectReference = v1.ObjectReference{Namespace: "default", Name: "migrated-pvc"}
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Sep 12 05:42:38 UTC 2023 - 10.4K bytes - Viewed (0) -
pkg/controller/podgc/gc_controller.go
item, quit := gcc.nodeQueue.Get() if quit { return nil, true } nodeName := item if !existingNodeNames.Has(nodeName) { exists, err := gcc.checkIfNodeExists(ctx, nodeName) switch { case err != nil: klog.FromContext(ctx).Error(err, "Error while getting node", "node", klog.KRef("", nodeName)) // Node will be added back to the queue in the subsequent loop if still needed case !exists:
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 13.3K bytes - Viewed (0) -
pkg/controller/controller_utils_test.go
Spec: v1.PodSpec{NodeName: "foo"}, Status: v1.PodStatus{Phase: v1.PodUnknown}, }, { ObjectMeta: metav1.ObjectMeta{Name: "runningButNotReady"}, Spec: v1.PodSpec{NodeName: "foo"}, Status: v1.PodStatus{Phase: v1.PodRunning}, }, { ObjectMeta: metav1.ObjectMeta{Name: "runningNoLastTransitionTime"}, Spec: v1.PodSpec{NodeName: "foo"},
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 39.4K bytes - Viewed (0) -
platforms/core-configuration/file-collections/src/main/java/org/gradle/api/internal/file/AbstractFileCollection.java
new AntFileCollectionMatchingTaskBuilder(getAsFileTrees()).addToAntBuilder(builder, nodeName); } protected void addAsFileSet(Object builder, String nodeName) { new AntFileSetBuilder(getAsFileTrees()).addToAntBuilder(builder, nodeName); } protected void addAsResourceCollection(Object builder, String nodeName) { new AntFileCollectionBuilder(this).addToAntBuilder(builder, nodeName);
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Apr 23 07:32:50 UTC 2024 - 13.5K 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/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)