- Sort Score
- Result 10 results
- Languages All
Results 1 - 2 of 2 for rotateLogs (0.12 sec)
-
pkg/kubelet/logs/container_log_manager.go
return } if err := c.rotateLog(ctx, id, path); err != nil { klog.ErrorS(err, "Failed to rotate log for container", "worker", worker, "containerID", id, "path", path, "currentSize", info.Size(), "maxSize", c.policy.MaxSize) return } return } func (c *containerLogManager) rotateLog(ctx context.Context, id, log string) error { // pattern is used to match all rotated files.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 15K bytes - Viewed (0) -
pkg/kubelet/logs/container_log_manager_test.go
}, }, } f.SetFakeContainers(testContainers) // Push the items into the queue for before starting the worker to avoid issue with the queue being empty. require.NoError(t, c.rotateLogs(ctx)) // Start a routine that can monitor the queue and shutdown the queue to trigger the retrun from the processQueueItems // Keeping the monitor duration smaller in order to keep the unwanted delay in the test to a minimal.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 12.7K bytes - Viewed (0)