Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for rotateLogs (0.12 sec)

  1. 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)
  2. 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)
Back to top