Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for newTestWorker (0.14 sec)

  1. 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)
  2. 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)
Back to top