- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 12 for removeContainers (0.21 sec)
-
cmd/kubeadm/app/util/runtime/runtime_test.go
containerRuntime := NewContainerRuntime("") mock := &fakeImpl{} if tc.prepare != nil { tc.prepare(mock) } containerRuntime.SetImpl(mock) err := containerRuntime.RemoveContainers(tc.containers) assert.Equal(t, tc.shouldError, err != nil) }) } } func TestPullImage(t *testing.T) { for _, tc := range []struct { name string prepare func(*fakeImpl)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 30 06:33:22 UTC 2024 - 11.1K bytes - Viewed (0) -
subprojects/core/src/integTest/groovy/org/gradle/api/FinalizerTaskIntegrationTest.groovy
finalizedBy 'dockerStop' // dependsOn removeContainer } task dockerUp(type: BreakingTask) { dependsOn 'createContainer' } task dockerStop(type: BreakingTask) { dependsOn 'removeContainer' }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri May 17 13:27:33 UTC 2024 - 32.3K bytes - Viewed (0) -
pkg/kubelet/cm/cpumanager/cpu_manager.go
AddContainer(p *v1.Pod, c *v1.Container, containerID string) // RemoveContainer is called after Kubelet decides to kill or delete a // container. After this call, the CPU manager stops trying to reconcile // that container and any CPUs dedicated to the container are freed. RemoveContainer(containerID string) error // State returns a read-only interface to the internal CPU manager state.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 03 16:26:09 UTC 2023 - 19.9K bytes - Viewed (0) -
pkg/kubelet/cm/memorymanager/memory_manager.go
Allocate(pod *v1.Pod, container *v1.Container) error // RemoveContainer is called after Kubelet decides to kill or delete a // container. After this call, any memory allocated to the container is freed. RemoveContainer(containerID string) error // State returns a read-only interface to the internal memory manager state. State() state.Reader
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Nov 01 00:50:45 UTC 2023 - 17.1K bytes - Viewed (1) -
pkg/kubelet/cm/cpumanager/policy_static_test.go
testCase.description, testCase.expCSetAfterAlloc, st.defaultCPUSet) } // remove policy.RemoveContainer(st, string(pod.UID), testCase.containerName) if !reflect.DeepEqual(st.defaultCPUSet, testCase.expCSetAfterRemove) { t.Errorf("StaticPolicy RemoveContainer() error (%v). expected default cpuset %v but got %v", testCase.description, testCase.expCSetAfterRemove, st.defaultCPUSet) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 40.8K bytes - Viewed (0) -
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_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/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)