- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 31 for removeContainers (0.19 sec)
-
pkg/kubelet/kuberuntime/instrumented_services.go
recordError(operation, err) return err } func (in instrumentedRuntimeService) RemoveContainer(ctx context.Context, containerID string) error { const operation = "remove_container" defer recordOperation(operation, time.Now()) err := in.service.RemoveContainer(ctx, containerID) recordError(operation, err) return err }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 10:46:06 UTC 2024 - 13.1K bytes - Viewed (0) -
pkg/kubelet/cm/cpumanager/cpu_manager_test.go
activePods: func() []*v1.Pod { return nil }, podStatusProvider: mockPodStatusProvider{}, } containerMap.Add("", "", containerID) err := mgr.RemoveContainer(containerID) if err != nil { t.Errorf("CPU Manager RemoveContainer() error. expected error to be nil but got: %v", err) } mgr = &manager{ policy: &mockPolicy{ err: fmt.Errorf("fake error"), },
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Oct 06 13:16:15 UTC 2023 - 42.9K bytes - Viewed (0) -
pkg/kubelet/kuberuntime/kuberuntime_container.go
} // prune all other init containers that match this container name klog.V(4).InfoS("Removing init container", "containerName", status.Name, "containerID", status.ID.ID, "count", count) if err := m.removeContainer(ctx, status.ID.ID); err != nil { utilruntime.HandleError(fmt.Errorf("failed to remove pod init container %q: %v; Skipping pod %q", status.Name, err, format.Pod(pod))) continue } } } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 54.7K bytes - Viewed (0) -
platforms/documentation/docs/src/docs/userguide/releases/upgrading/upgrading_version_7.adoc
finalizedBy("dockerStop") // dependsOn removeContainer } register("dockerUp") { dependsOn("createContainer") } register("dockerStop") { dependsOn("removeContainer") } register("createContainer") { mustRunAfter("removeContainer") }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Apr 01 15:00:23 UTC 2024 - 87.7K bytes - Viewed (0) -
pkg/kubelet/kuberuntime/kuberuntime_container_test.go
expectedContainerLogSymlink := legacyLogSymlink(containerID, "foo", "bar", "new") fakeOS.Create(expectedContainerLogPath) fakeOS.Create(expectedContainerLogPathRotated) err = m.removeContainer(ctx, containerID) assert.NoError(t, err) // Verify container log is removed. // We could not predict the order of `fakeOS.Removes`, so we use `assert.ElementsMatch` here. assert.ElementsMatch(t,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 29 22:40:29 UTC 2024 - 28K bytes - Viewed (0) -
pkg/kubelet/cm/memorymanager/memory_manager_test.go
mgr.state.SetMemoryAssignments(testCase.assignments) mgr.state.SetMachineState(testCase.machineState) err := mgr.RemoveContainer(testCase.removeContainerID) if !reflect.DeepEqual(err, testCase.expectedError) { t.Errorf("Memory Manager RemoveContainer() error (%v), expected error: %v, but got: %v", testCase.description, testCase.expectedError, err) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 05 13:01:40 UTC 2023 - 70.2K bytes - Viewed (0) -
pkg/kubelet/cm/memorymanager/policy_static.go
if !ok { return 0 } return numaReusableMemory[resourceName] } // RemoveContainer call is idempotent func (p *staticPolicy) RemoveContainer(s state.State, podUID string, containerName string) { blocks := s.GetMemoryBlocks(podUID, containerName) if blocks == nil { return } klog.InfoS("RemoveContainer", "podUID", podUID, "containerName", containerName) s.Delete(podUID, containerName)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Nov 12 07:34:55 UTC 2023 - 34K bytes - Viewed (0) -
pkg/kubelet/cm/cpumanager/policy_static.go
if containerName == name { continue } cset = cset.Union(cpus) } return cset } func (p *staticPolicy) RemoveContainer(s state.State, podUID string, containerName string) error { klog.InfoS("Static policy: RemoveContainer", "podUID", podUID, "containerName", containerName) cpusInUse := getAssignedCPUsOfSiblings(s, podUID, containerName)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Oct 06 13:16:15 UTC 2023 - 28.8K bytes - Viewed (0) -
pkg/kubelet/kuberuntime/kuberuntime_gc.go
klog.ErrorS(err, "Failed to stop container", "containerID", containers[i].id) continue } } if err := cgc.manager.removeContainer(ctx, containers[i].id); err != nil { klog.ErrorS(err, "Failed to remove container", "containerID", containers[i].id) } } // Assume we removed the containers so that we're not too aggressive.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 15.3K bytes - Viewed (0) -
pkg/kubelet/kuberuntime/kuberuntime_gc_test.go
}) fakeRuntime.SetFakeContainers(fakeContainers) err = m.containerGC.evictContainers(ctx, defaultGCPolicy, true, false) assert.NoError(t, err) assert.Contains(t, fakeRuntime.GetCalls(), "StopContainer", "RemoveContainer", "container in unknown state should be stopped before being removed") remain, err := fakeRuntime.ListContainers(ctx, nil) assert.NoError(t, err) assert.Empty(t, remain)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 08:12:16 UTC 2024 - 20.6K bytes - Viewed (0)