Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for GenericPLEG (0.34 sec)

  1. pkg/kubelet/pleg/generic.go

    	"k8s.io/kubernetes/pkg/kubelet/metrics"
    	"k8s.io/utils/clock"
    )
    
    // GenericPLEG is an extremely simple generic PLEG that relies solely on
    // periodic listing to discover container changes. It should be used
    // as temporary replacement for container runtimes do not support a proper
    // event generator yet.
    //
    // Note that GenericPLEG assumes that a container would not be created,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 19.3K bytes
    - Viewed (0)
  2. pkg/kubelet/pleg/evented.go

    	cache kubecontainer.Cache, genericPleg PodLifecycleEventGenerator, eventedPlegMaxStreamRetries int,
    	relistDuration *RelistDuration, clock clock.Clock) (PodLifecycleEventGenerator, error) {
    	handler, ok := genericPleg.(podLifecycleEventGeneratorHandler)
    	if !ok {
    		return nil, fmt.Errorf("%v doesn't implement podLifecycleEventGeneratorHandler interface", genericPleg)
    	}
    	return &EventedPLEG{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 07 10:46:06 UTC 2024
    - 16.4K bytes
    - Viewed (0)
  3. pkg/kubelet/pleg/generic_test.go

    	}
    	actual := getEventsFromChannel(ch)
    	verifyEvents(t, expected, actual)
    }
    
    func newTestGenericPLEGWithRuntimeMock(runtimeMock kubecontainer.Runtime) *GenericPLEG {
    	pleg := &GenericPLEG{
    		relistDuration: &RelistDuration{RelistPeriod: time.Hour, RelistThreshold: 2 * time.Hour},
    		runtime:        runtimeMock,
    		eventChannel:   make(chan *PodLifecycleEvent, 1000),
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 07 08:12:16 UTC 2024
    - 24.8K bytes
    - Viewed (0)
Back to top