- Sort Score
- Result 10 results
- Languages All
Results 1 - 5 of 5 for deleteCount (0.42 sec)
-
pkg/controller/podgc/gc_controller.go
terminatedPodCount := len(terminatedPods) deleteCount := terminatedPodCount - gcc.terminatedPodThreshold if deleteCount <= 0 { return } logger := klog.FromContext(ctx) logger.Info("Garbage collecting pods", "numPods", deleteCount) // sort only when necessary sort.Sort(byEvictionAndCreationTimestamp(terminatedPods)) var wait sync.WaitGroup for i := 0; i < deleteCount; i++ { wait.Add(1)
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/registry/core/pod/storage/eviction_test.go
t.Errorf("error mismatch: expected %v, got %v; name %v", tc.expectError, gotErr, pod.Name) return } if tc.expectedDeleteCount != ms.deleteCount { t.Errorf("expected delete count=%v, got %v; name %v", tc.expectedDeleteCount, ms.deleteCount, pod.Name) } }) } } } func TestEvictionDryRun(t *testing.T) { testcases := []struct { name string
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 09:26:37 UTC 2024 - 40K bytes - Viewed (0) -
cmd/xl-storage.go
return 0 } return binary.LittleEndian.Uint64(buf[:8]) } func (s *xlStorage) setDeleteAttribute(deleteCount uint64) error { attr := "user.total_deletes" data := make([]byte, 8) binary.LittleEndian.PutUint64(data, deleteCount) return xattr.LSet(s.formatFile, attr, data) } func (s *xlStorage) setWriteAttribute(writeCount uint64) error { attr := "user.total_writes"
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:51:27 UTC 2024 - 85.3K bytes - Viewed (0) -
pkg/controller/daemon/daemon_controller.go
// retry the slow start process. break } } logger.V(4).Info("Pods to delete for daemon set, deleting", "daemonset", klog.KObj(ds), "toDeleteCount", podsToDelete, "deleteCount", deleteDiff) deleteWait := sync.WaitGroup{} deleteWait.Add(deleteDiff) for i := 0; i < deleteDiff; i++ { go func(ix int) { defer deleteWait.Done()
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/pod/testing/fake_mirror_client.go
// itself. This fake manager does this to track calls. mirrorPods sets.Set[string] createCounts map[string]int deleteCounts map[string]int } func NewFakeMirrorClient() *FakeMirrorClient { m := FakeMirrorClient{} m.mirrorPods = sets.New[string]() m.createCounts = make(map[string]int) m.deleteCounts = make(map[string]int) return &m } func (fmc *FakeMirrorClient) CreateMirrorPod(pod *v1.Pod) error {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 2.4K bytes - Viewed (0)