- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 11 for orphaned (0.33 sec)
-
pkg/kubelet/pod_workers_test.go
}, orphan: true, removed: false, }, { desc: "orphaned terminating worker with no activeUpdate", podSyncStatus: &podSyncStatus{ startedAt: time.Unix(1, 0), terminatingAt: time.Unix(2, 0), finished: false, fullname: "fake-fullname", }, orphan: true, removed: false, }, { desc: "orphaned terminating worker",
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 75.6K bytes - Viewed (0) -
pkg/kubelet/cm/devicemanager/manager_test.go
// Tests that the device plugin manager correctly handles registration and re-registration by // making sure that after registration, devices are correctly updated and if a re-registration // happens, we will NOT delete devices; and no orphaned devices left. func TestDevicePluginReRegistration(t *testing.T) { // TODO: Remove skip once https://github.com/kubernetes/kubernetes/pull/115269 merges. if goruntime.GOOS == "windows" {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 65K bytes - Viewed (0) -
pkg/kubelet/status/status_manager_test.go
mirrorPod.Name = "mirror_pod" mirrorPod.Annotations = map[string]string{ kubetypes.ConfigSourceAnnotationKey: "api", kubetypes.ConfigMirrorAnnotationKey: "mirror", } t.Logf("Orphaned pods should be removed.") m.apiStatusVersions[kubetypes.MirrorPodUID(testPod.UID)] = 100 m.apiStatusVersions[kubetypes.MirrorPodUID(mirrorPod.UID)] = 200 m.syncBatch(true)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 02 16:27:19 UTC 2024 - 68.1K bytes - Viewed (0) -
pkg/controller/daemon/daemon_controller.go
dsc.enqueueDaemonSet(ds) return } // Otherwise, it's an orphan. Get a list of all matching DaemonSets and sync // them to see if anyone wants to adopt it. // DO NOT observe creation because no controller should be waiting for an // orphan. dss := dsc.getDaemonSetsForPod(pod) if len(dss) == 0 { return } logger.V(4).Info("Orphan Pod added", "pod", klog.KObj(pod)) for _, ds := range dss {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 51.3K bytes - Viewed (0) -
pkg/kubelet/volumemanager/populator/desired_state_of_world_populator_test.go
dswp.ReprocessPod(podName) dswp.findAndRemoveDeletedPods() // findAndRemoveDeletedPods() above must detect orphaned pod and delete it from the map if _, ok := dswp.pods.processedPods[podName]; ok { t.Fatalf("Failed to remove orphanded pods from internal map") } volumeExists := dswp.desiredStateOfWorld.VolumeExists(expectedVolumeName, "" /* SELinuxContext */) if volumeExists {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 51.4K bytes - Viewed (0) -
platforms/software/dependency-management/src/integTest/groovy/org/gradle/integtests/resolve/versions/VersionConflictResolutionIntegrationTest.groovy
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu May 09 11:33:46 UTC 2024 - 76.2K bytes - Viewed (0) -
pkg/proxy/winkernel/proxier.go
svcInfo.cleanupAllPolicies(proxier.endpointsMap[*svcPortName], proxier.mapStaleLoadbalancers, true) } else { // If no service exists, just cleanup the remote endpoints klog.V(3).InfoS("Endpoints are orphaned, cleaning up") // Cleanup Endpoints references epInfos, exists := proxier.endpointsMap[*svcPortName] if exists { // Cleanup Endpoints references for _, ep := range epInfos {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 13:25:06 UTC 2024 - 59K bytes - Viewed (0) -
pkg/controller/job/job_controller.go
return } // Otherwise, it's an orphan. // Clean the finalizer. if hasJobTrackingFinalizer(pod) { jm.enqueueOrphanPod(pod) } // Get a list of all matching controllers and sync // them to see if anyone wants to adopt it. // DO NOT observe creation because no controller should be waiting for an // orphan. for _, job := range jm.getPodJobs(pod) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jun 10 23:56:37 UTC 2024 - 77.6K bytes - Viewed (0) -
pkg/controller/volume/persistentvolume/pv_controller.go
logger.V(3).Info("Failed to delete volume", "volumeName", volume.Name, "err", deleteErr) time.Sleep(ctrl.createProvisionedPVInterval) } if deleteErr != nil { // Delete failed several times. There is an orphaned volume and there // is nothing we can do about it. strerr := fmt.Sprintf("Error cleaning provisioned volume for claim %s: %v. Please delete manually.", claimToClaimKey(claim), deleteErr) logger.V(2).Info(strerr)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 10 08:42:31 UTC 2024 - 89.2K bytes - Viewed (0) -
pkg/controller/replicaset/replica_set_test.go
t.Errorf("Expected keys %#v got %v", expected, got) } case <-time.After(wait.ForeverTestTimeout): t.Errorf("Expected update notifications for replica sets") } } // case 2: Remove ControllerRef (orphan). Expect to sync label-matching RS. pod1 = newPodList(informers.Core().V1().Pods().Informer().GetIndexer(), 1, v1.PodRunning, labelMap1, testRSSpec1, "pod").Items[0] pod1.ResourceVersion = "1" pod1.Labels = labelMap2
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 69.2K bytes - Viewed (0)