- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 415 for prober (0.17 sec)
-
pilot/cmd/pilot-agent/status/server.go
} if prober.HTTPGet != nil && prober.HTTPGet.Port.Type != apimirror.Int { return fmt.Errorf("invalid prober config for %v, the port must be int type", path) } if prober.TCPSocket != nil && prober.TCPSocket.Port.Type != apimirror.Int { return fmt.Errorf("invalid prober config for %v, the port must be int type", path) } return nil }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 15:07:03 UTC 2024 - 31.1K bytes - Viewed (1) -
pkg/volume/flexvolume/probe_test.go
assert.NoError(t, err) // Should no longer probe. // Act events, err = prober.Probe() // Assert assert.Equal(t, 0, len(events)) assert.NoError(t, err) } // Probes newly added drivers after prober is running. func TestProberAddRemoveDriver(t *testing.T) { // Arrange _, fs, watcher, prober := initTestEnvironment(t) prober.Probe() events, err := prober.Probe() assert.NoError(t, err)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Nov 28 11:14:00 UTC 2023 - 10.5K bytes - Viewed (0) -
pkg/kubelet/prober/prober_manager.go
// readinessManager manages the results of readiness probes readinessManager results.Manager // livenessManager manages the results of liveness probes livenessManager results.Manager // startupManager manages the results of startup probes startupManager results.Manager // prober executes the probe actions. prober *prober start time.Time }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jul 07 22:26:12 UTC 2023 - 11K bytes - Viewed (0) -
pkg/kubelet/prober/worker_test.go
} // Exceeding FailureThreshold should cause resultRun to // reset to 0 so that the probe on the restarted pod // also gets FailureThreshold attempts to succeed. m.prober.exec = fakeExecProber{probe.Failure, nil} msg = "3rd probe failure, result failure" expectContinue(t, w, w.doProbe(ctx), msg) expectResult(t, w, results.Failure, msg) if w.resultRun != 0 {
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/prober_manager_test.go
m.CleanupPods(desiredPods) removedProbes := []probeKey{ {"pod_cleanup", "prober1", readiness}, {"pod_cleanup", "prober2", liveness}, {"pod_cleanup", "prober3", startup}, } expectedProbes := []probeKey{ {"pod_keep", "prober1", readiness}, {"pod_keep", "prober2", liveness}, {"pod_keep", "prober3", startup}, } if err := waitForWorkerExit(t, m, removedProbes); err != nil { t.Fatal(err) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 18.8K bytes - Viewed (0) -
pkg/probe/http/http_test.go
redirect string expectLocalResult probe.Result expectNonLocalResult probe.Result }{ "local success": {"/success", probe.Success, probe.Success}, "local fail": {"/fail", probe.Failure, probe.Failure}, "newport success": {newportServer.URL + "/success", probe.Success, probe.Success}, "newport fail": {newportServer.URL + "/fail", probe.Failure, probe.Failure},
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Apr 18 01:40:08 UTC 2023 - 15.7K bytes - Viewed (0) -
pkg/kubelet/prober/worker.go
return true } } else { // Disable other probes until container has started. if w.probeType != startup { return true } } // Note, exec probe does NOT have access to pod environment variables or downward API result, err := w.probeManager.prober.probe(ctx, w.probeType, w.pod, status, w.container, w.containerID) if err != nil { // Prober error, throw away the result. return true }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jul 27 01:28:06 UTC 2023 - 10.7K bytes - Viewed (0) -
pilot/cmd/pilot-agent/status/server_test.go
testCases := []struct { name string probes []ready.Prober err error }{ { name: "success probe", probes: []ready.Prober{rp}, err: nil, }, { name: "not ready probe", probes: []ready.Prober{urp}, err: errors.New("not ready"), }, { name: "both probes", probes: []ready.Prober{rp, urp}, err: errors.New("not ready"),
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 15:07:03 UTC 2024 - 42.6K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/storagebackend/factory/etcd3.go
} if err != nil { clientErr = err return false, nil } prober = newProber clientErr = nil return true, nil }, stopCh) // Close the client on shutdown. go func() { defer utilruntime.HandleCrash() <-stopCh lock.Lock() defer lock.Unlock() if prober != nil { prober.Close() clientErr = fmt.Errorf("server is shutting down") } }()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 07:56:39 UTC 2024 - 15.1K bytes - Viewed (0) -
pkg/volume/plugins.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jun 06 16:13:15 UTC 2024 - 38.2K bytes - Viewed (0)