- Sort Score
- Result 10 results
- Languages All
Results 1 - 2 of 2 for newTestWorker (0.14 sec)
-
pkg/kubelet/prober/worker_test.go
startup.String(): true, }, expectSet: true, expectedResult: results.Success, }, } for i, test := range tests { ctx := context.Background() w := newTestWorker(m, probeType, test.probe) if test.podStatus != nil { m.statusManager.SetPodStatus(w.pod, *test.podStatus) } if test.setDeletionTimestamp { now := metav1.Now()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 07 23:48:10 UTC 2023 - 16.1K bytes - Viewed (0) -
pkg/kubelet/prober/common_test.go
results.NewManager(), nil, // runner &record.FakeRecorder{}, ).(*manager) // Don't actually execute probes. m.prober.exec = fakeExecProber{probe.Success, nil} return m } func newTestWorker(m *manager, probeType probeType, probeSpec v1.Probe) *worker { pod := getTestPod() setTestProbe(pod, probeType, probeSpec) return newWorker(m, probeType, pod, pod.Spec.Containers[0]) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 12 16:57:26 UTC 2023 - 4.3K bytes - Viewed (0)