Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for IsTerminationRequested (0.7 sec)

  1. pkg/kubelet/pod_workers.go

    	// it has been started.
    	observedRuntime bool
    }
    
    func (s *podSyncStatus) IsWorking() bool              { return s.working }
    func (s *podSyncStatus) IsTerminationRequested() bool { return !s.terminatingAt.IsZero() }
    func (s *podSyncStatus) IsTerminationStarted() bool   { return s.startedTerminating }
    func (s *podSyncStatus) IsTerminated() bool           { return !s.terminatedAt.IsZero() }
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Apr 02 13:22:37 UTC 2024
    - 74.8K bytes
    - Viewed (0)
  2. pkg/kubelet/kubelet_pods_test.go

    				uid := types.UID("1")
    				if len(w.podSyncStatuses) != 1 {
    					t.Fatalf("unexpected sync statuses: %#v", w.podSyncStatuses)
    				}
    				s, ok := w.podSyncStatuses[uid]
    				if !ok || !s.IsTerminationRequested() || !s.IsTerminationStarted() || s.IsFinished() || s.IsWorking() || !s.IsDeleted() {
    					t.Fatalf("unexpected requested pod termination: %#v", s)
    				}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 07 00:05:23 UTC 2024
    - 198.8K bytes
    - Viewed (0)
  3. pkg/kubelet/pod_workers_test.go

    		UpdateType: kubetypes.SyncPodUpdate,
    	})
    	drainAllWorkers(podWorkers)
    
    	// should observe pod terminating
    	pod1 = podWorkers.podSyncStatuses[types.UID("1")]
    	if !pod1.IsTerminationRequested() || !pod1.IsTerminated() {
    		t.Fatalf("unexpected pod state: %#v", pod1)
    	}
    }
    
    func TestStaticPodExclusion(t *testing.T) {
    	if testing.Short() {
    		t.Skip("skipping test in short mode.")
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 75.6K bytes
    - Viewed (0)
Back to top