- Sort Score
- Result 10 results
- Languages All
Results 1 - 4 of 4 for SyncTerminatingRuntimePod (0.43 sec)
-
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) -
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) -
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) -
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)