- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for GenericPLEG (0.34 sec)
-
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) -
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) -
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)