- Sort Score
- Result 10 results
- Languages All
Results 1 - 5 of 5 for syncTerminatingPod (0.27 sec)
-
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) -
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) -
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) -
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) -
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)