Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 76 for pleg (0.1 sec)

  1. pkg/kubelet/pleg/generic_test.go

    	assert.False(t, ok, "pleg should be unhealthy")
    
    	// Advance the clock without any relisting.
    	clock.Step(time.Minute * 10)
    	ok, _ = pleg.Healthy()
    	assert.False(t, ok, "pleg should be unhealthy")
    
    	// Relist and than advance the time by 1 minute. pleg should be healthy
    	// because this is within the allowed limit.
    	pleg.Relist()
    	clock.Step(time.Minute * 1)
    	ok, _ = pleg.Healthy()
    	assert.True(t, ok, "pleg should be healthy")
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 07 08:12:16 UTC 2024
    - 24.8K bytes
    - Viewed (0)
  2. pkg/kubelet/pleg/generic.go

    	// retried during the next relisting.
    	podsToReinspect map[types.UID]*kubecontainer.Pod
    	// Stop the Generic PLEG by closing the channel.
    	stopCh chan struct{}
    	// Locks the relisting of the Generic PLEG
    	relistLock sync.Mutex
    	// Indicates if the Generic PLEG is running or not
    	isRunning bool
    	// Locks the start/stop operation of Generic PLEG
    	runningMu sync.Mutex
    	// Indicates relisting related parameters
    	relistDuration *RelistDuration
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 19.3K bytes
    - Viewed (0)
  3. pkg/kubelet/pleg/evented.go

    				if isEventedPLEGInUse() {
    					// Fall back to Generic PLEG relisting since Evented PLEG is not working.
    					klog.V(4).InfoS("Fall back to Generic PLEG relisting since Evented PLEG is not working")
    					e.Stop()
    					e.genericPleg.Stop()       // Stop the existing Generic PLEG which runs with longer relisting period when Evented PLEG is in use.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 07 10:46:06 UTC 2024
    - 16.4K bytes
    - Viewed (0)
  4. pkg/kubelet/kubelet.go

    		}
    		klet.pleg = pleg.NewGenericPLEG(klet.containerRuntime, eventChannel, genericRelistDuration, klet.podCache, clock.RealClock{})
    		// In case Evented PLEG has to fall back on Generic PLEG due to an error,
    		// Evented PLEG should be able to reset the Generic PLEG relisting duration
    		// to the default value.
    		eventedRelistDuration := &pleg.RelistDuration{
    			RelistPeriod:    genericPlegRelistPeriod,
    			RelistThreshold: genericPlegRelistThreshold,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 16:09:17 UTC 2024
    - 126.1K bytes
    - Viewed (0)
  5. pkg/kubelet/metrics/metrics.go

    	// Pod Lifecycle Event Generator (PLEG).
    	PLEGRelistDuration = metrics.NewHistogram(
    		&metrics.HistogramOpts{
    			Subsystem:      KubeletSubsystem,
    			Name:           PLEGRelistDurationKey,
    			Help:           "Duration in seconds for relisting pods in PLEG.",
    			Buckets:        metrics.DefBuckets,
    			StabilityLevel: metrics.ALPHA,
    		},
    	)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Feb 22 15:13:25 UTC 2024
    - 45.6K bytes
    - Viewed (0)
  6. pkg/kubelet/kubelet_test.go

    	kubelet.resyncInterval = 10 * time.Second
    	kubelet.workQueue = queue.NewBasicWorkQueue(fakeClock)
    	// Relist period does not affect the tests.
    	kubelet.pleg = pleg.NewGenericPLEG(fakeRuntime, make(chan *pleg.PodLifecycleEvent, 100), &pleg.RelistDuration{RelistPeriod: time.Hour, RelistThreshold: genericPlegRelistThreshold}, kubelet.podCache, clock.RealClock{})
    	kubelet.clock = fakeClock
    
    	nodeRef := &v1.ObjectReference{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 16:09:17 UTC 2024
    - 106.9K bytes
    - Viewed (0)
  7. pkg/kubelet/kuberuntime/helpers.go

    }
    
    // sandboxToKubeContainer converts runtimeapi.PodSandbox to kubecontainer.Container.
    // This is only needed because we need to return sandboxes as if they were
    // kubecontainer.Containers to avoid substantial changes to PLEG.
    // TODO: Remove this once it becomes obsolete.
    func (m *kubeGenericRuntimeManager) sandboxToKubeContainer(s *runtimeapi.PodSandbox) (*kubecontainer.Container, error) {
    	if s == nil || s.Id == "" {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 22 02:01:31 UTC 2024
    - 12K bytes
    - Viewed (0)
  8. pkg/kubelet/container/helpers.go

    // SandboxToContainerState converts runtimeapi.PodSandboxState to
    // kubecontainer.State.
    // This is only needed because we need to return sandboxes as if they were
    // kubecontainer.Containers to avoid substantial changes to PLEG.
    // TODO: Remove this once it becomes obsolete.
    func SandboxToContainerState(state runtimeapi.PodSandboxState) State {
    	switch state {
    	case runtimeapi.PodSandboxState_SANDBOX_READY:
    		return ContainerStateRunning
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 14.3K bytes
    - Viewed (0)
  9. pkg/kubelet/kuberuntime/kuberuntime_manager.go

    			if resp.Timestamp == 0 {
    				// If the Evented PLEG is enabled in the kubelet, but not in the runtime
    				// then the pod status we get will not have the timestamp set.
    				// e.g. CI job 'pull-kubernetes-e2e-gce-alpha-features' will runs with
    				// features gate enabled, which includes Evented PLEG, but uses the
    				// runtime without Evented PLEG support.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 22 02:01:31 UTC 2024
    - 64.7K bytes
    - Viewed (0)
  10. pkg/features/kube_features.go

    	DynamicResourceAllocation featuregate.Feature = "DynamicResourceAllocation"
    
    	// owner: @harche
    	// kep: http://kep.k8s.io/3386
    	// alpha: v1.25
    	//
    	// Allows using event-driven PLEG (pod lifecycle event generator) through kubelet
    	// which avoids frequent relisting of containers which helps optimize performance.
    	EventedPLEG featuregate.Feature = "EventedPLEG"
    
    	// owner: @andrewsykim @SergeyKanzhelev
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 22:51:23 UTC 2024
    - 45.2K bytes
    - Viewed (0)
Back to top