Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for SyncTerminatingRuntimePod (0.43 sec)

  1. pkg/kubelet/pod_workers.go

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

    // place to send that status.
    func (kl *Kubelet) SyncTerminatingRuntimePod(_ context.Context, runningPod *kubecontainer.Pod) error {
    	// TODO(#113606): connect this with the incoming context parameter, which comes from the pod worker.
    	// Currently, using that context causes test failures.
    	ctx := context.Background()
    	pod := runningPod.ToAPIPod()
    	klog.V(4).InfoS("SyncTerminatingRuntimePod enter", "pod", klog.KObj(pod), "podUID", pod.UID)
    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

    						name:        pod.Name,
    						updateType:  kubetypes.SyncPodKill,
    						gracePeriod: gracePeriod,
    					})
    				}()
    				return nil
    			},
    			syncTerminatingRuntimePod: func(ctx context.Context, runningPod *kubecontainer.Pod) error {
    				func() {
    					lock.Lock()
    					defer lock.Unlock()
    					processed[runningPod.ID] = append(processed[runningPod.ID], syncPodRecord{
    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

    						t.Fatalf("unexpected error in syncTerminatingPodFn: %v", err)
    					}
    					return tt.terminatingErr
    				}
    				syncFuncs.syncTerminatingRuntimePod = func(ctx context.Context, runningPod *kubecontainer.Pod) error {
    					if err := originalPodSyncer.SyncTerminatingRuntimePod(ctx, runningPod); err != nil {
    						t.Fatalf("unexpected error in syncTerminatingRuntimePodFn: %v", err)
    					}
    					return tt.terminatingErr
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 07 00:05:23 UTC 2024
    - 198.8K bytes
    - Viewed (0)
Back to top