Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for kubelet_log_rotate_manager (0.19 sec)

  1. pkg/kubelet/logs/container_log_manager_test.go

    		mutex:       sync.Mutex{},
    		queue: workqueue.NewTypedRateLimitingQueueWithConfig(
    			workqueue.DefaultTypedControllerRateLimiter[string](),
    			workqueue.TypedRateLimitingQueueConfig[string]{Name: "kubelet_log_rotate_manager"},
    		),
    		maxWorkers:       10,
    		monitoringPeriod: v1.Duration{Duration: 10 * time.Second},
    	}
    	testLogs := []string{
    		"test-log-1",
    		"test-log-2",
    		"test-log-3",
    		"test-log-4",
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 12.7K bytes
    - Viewed (0)
  2. pkg/kubelet/logs/container_log_manager.go

    		maxWorkers: maxWorkers,
    		queue: workqueue.NewTypedRateLimitingQueueWithConfig(
    			workqueue.DefaultTypedControllerRateLimiter[string](),
    			workqueue.TypedRateLimitingQueueConfig[string]{Name: "kubelet_log_rotate_manager"},
    		),
    		monitoringPeriod: monitorInterval,
    	}, nil
    }
    
    // Start the container log manager.
    func (c *containerLogManager) Start() {
    	ctx := context.Background()
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 15K bytes
    - Viewed (0)
Back to top