Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for syncTerminatingPod (0.34 sec)

  1. pkg/kubelet/pod_workers.go

    	syncPod                   syncPodFnType
    	syncTerminatingPod        syncTerminatingPodFnType
    	syncTerminatingRuntimePod syncTerminatingRuntimePodFnType
    	syncTerminatedPod         syncTerminatedPodFnType
    }
    
    func newPodSyncerFuncs(s podSyncer) podSyncerFuncs {
    	return podSyncerFuncs{
    		syncPod:                   s.SyncPod,
    		syncTerminatingPod:        s.SyncTerminatingPod,
    		syncTerminatingRuntimePod: s.SyncTerminatingRuntimePod,
    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.go

    // pods.
    func (kl *Kubelet) SyncTerminatingPod(_ context.Context, pod *v1.Pod, podStatus *kubecontainer.PodStatus, gracePeriod *int64, podStatusFn func(*v1.PodStatus)) error {
    	// TODO(#113606): connect this with the incoming context parameter, which comes from the pod worker.
    	// Currently, using that context causes test failures.
    	ctx, otelSpan := kl.tracer.Start(context.Background(), "syncTerminatingPod", trace.WithAttributes(
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 16:09:17 UTC 2024
    - 126.1K bytes
    - Viewed (0)
  3. pkg/kubelet/pod_workers_test.go

    					pod := pod
    					processed[pod.UID] = append(processed[pod.UID], syncPodRecord{
    						name:       pod.Name,
    						updateType: updateType,
    					})
    				}()
    				return false, nil
    			},
    			syncTerminatingPod: func(ctx context.Context, pod *v1.Pod, podStatus *kubecontainer.PodStatus, gracePeriod *int64, podStatusFn func(*v1.PodStatus)) error {
    				func() {
    					lock.Lock()
    					defer lock.Unlock()
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 75.6K bytes
    - Viewed (0)
  4. pkg/kubelet/kubelet_pods_test.go

    			podWorkers.podSyncer = &syncFuncs
    			if tt.terminatingErr != nil {
    				syncFuncs.syncTerminatingPod = func(ctx context.Context, pod *v1.Pod, podStatus *kubecontainer.PodStatus, gracePeriod *int64, podStatusFn func(*v1.PodStatus)) error {
    					t.Logf("called syncTerminatingPod")
    					if err := originalPodSyncer.SyncTerminatingPod(ctx, pod, podStatus, gracePeriod, podStatusFn); err != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 07 00:05:23 UTC 2024
    - 198.8K bytes
    - Viewed (0)
  5. pkg/kubelet/kubelet_test.go

    			Namespace: "foo",
    		},
    	}
    	pods := []*v1.Pod{pod}
    	kl.podManager.SetPods(pods)
    	podStatus := &kubecontainer.PodStatus{ID: pod.UID}
    	gracePeriodOverride := int64(0)
    	err := kl.SyncTerminatingPod(context.Background(), pod, podStatus, &gracePeriodOverride, func(podStatus *v1.PodStatus) {
    		podStatus.Phase = v1.PodFailed
    		podStatus.Reason = "reason"
    		podStatus.Message = "message"
    	})
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 16:09:17 UTC 2024
    - 106.9K bytes
    - Viewed (0)
Back to top