(ctx context.Context, woc *wfOperationCtx, podObjs ...apiv1.Pod)
| 526 | } |
| 527 | |
| 528 | func syncPodsInformer(ctx context.Context, woc *wfOperationCtx, podObjs ...apiv1.Pod) { |
| 529 | podcs := woc.controller.kubeclientset.CoreV1().Pods(woc.wf.GetNamespace()) |
| 530 | pods, err := podcs.List(ctx, metav1.ListOptions{}) |
| 531 | if err != nil { |
| 532 | panic(err) |
| 533 | } |
| 534 | podObjs = append(podObjs, pods.Items...) |
| 535 | for _, pod := range podObjs { |
| 536 | err = woc.controller.PodController.TestingPodInformer().GetIndexer().Add(&pod) |
| 537 | if err != nil { |
| 538 | panic(err) |
| 539 | } |
| 540 | } |
| 541 | } |
| 542 | |
| 543 | // makePodsPhase acts like a pod controller and simulates the transition of pods transitioning into a specified state |
| 544 | func makePodsPhase(ctx context.Context, woc *wfOperationCtx, phase apiv1.PodPhase, with ...with) { |
no test coverage detected