- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 359 for prober (0.13 sec)
-
staging/src/k8s.io/apiserver/pkg/storage/storagebackend/factory/factory.go
return newETCD3ProberMonitor(c) default: return nil, fmt.Errorf("unknown storage type: %s", c.Type) } } // Prober is an interface that defines the Probe function for doing etcd readiness/liveness checks. type Prober interface { Probe(ctx context.Context) error Close() error
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Aug 24 09:23:05 UTC 2023 - 3.3K bytes - Viewed (0) -
pkg/probe/grpc/grpc.go
"k8s.io/klog/v2" "k8s.io/kubernetes/pkg/probe" ) // Prober is an interface that defines the Probe function for doing GRPC readiness/liveness/startup checks. type Prober interface { Probe(host, service string, port int, timeout time.Duration) (probe.Result, string, error) } type grpcProber struct { } // New Prober for execute grpc probe func New() Prober { return grpcProber{} }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jan 25 19:28:03 UTC 2023 - 4K bytes - Viewed (0) -
pilot/cmd/pilot-agent/status/grpcready/probe.go
) var _ ready.Prober = &probe{} type probe struct { sync.RWMutex bootstrapPath string bootstrap *grpcxds.Bootstrap } // NewProbe returns a probe that checks if a valid bootstrap file can be loaded once. // If that bootstrap file has a file_watcher cert provider, we also ensure those certs exist. func NewProbe(bootstrapPath string) ready.Prober { return &probe{bootstrapPath: bootstrapPath} }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Oct 28 16:58:31 UTC 2021 - 1.9K bytes - Viewed (0) -
pkg/kubelet/prober/common_test.go
).(*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]) } type fakeExecProber struct { result probe.Result err error }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 12 16:57:26 UTC 2023 - 4.3K bytes - Viewed (0) -
pilot/cmd/pilot-agent/status/ready/probe.go
Check() error } var _ Prober = &Probe{} // Check executes the probe and returns an error if the probe fails. func (p *Probe) Check() error { // First, check that Envoy has received a configuration update from Pilot. if err := p.checkConfigStatus(); err != nil { return err } return p.isEnvoyReady() } // checkConfigStatus checks to make sure initial configs have been received from Pilot.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 02 00:35:05 UTC 2024 - 4.5K bytes - Viewed (0) -
pkg/probe/tcp/tcp_test.go
host string port int expectedStatus probe.Result expectedError error }{ // A connection is made and probing would succeed {tHost, tPort, probe.Success, nil}, // No connection can be made and probing would fail {tHost, -1, probe.Failure, nil}, } prober := New() for i, tt := range tests { status, _, err := prober.Probe(tt.host, tt.port, 1*time.Second) if status != tt.expectedStatus {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Apr 25 18:23:33 UTC 2017 - 1.8K bytes - Viewed (0) -
pkg/volume/nfs/nfs_test.go
if err != nil { t.Fatalf("error creating temp dir: %v", err) } defer os.RemoveAll(tmpDir) plugMgr := volume.VolumePluginMgr{} plugMgr.InitPlugins(ProbeVolumePlugins(volume.VolumeConfig{}), nil /* prober */, volumetest.NewFakeVolumeHost(t, tmpDir, nil, nil)) plug, err := plugMgr.FindPluginByName("kubernetes.io/nfs") if err != nil { t.Fatal("Can't find the plugin by name") }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Aug 01 15:56:32 UTC 2022 - 9K bytes - Viewed (0) -
pkg/kubelet/prober/testing/fake_manager.go
"k8s.io/apimachinery/pkg/util/sets" ) // FakeManager simulates a prober.Manager for testing. type FakeManager struct{} // Unused methods below. // AddPod simulates adding a Pod. func (FakeManager) AddPod(_ *v1.Pod) {} // RemovePod simulates removing a Pod. func (FakeManager) RemovePod(_ *v1.Pod) {} // Simulated stopping liveness and startup probes. func (FakeManager) StopLivenessAndStartup(_ *v1.Pod) {}
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jul 07 22:26:12 UTC 2023 - 1.4K bytes - Viewed (0) -
pkg/probe/exec/exec_test.go
err error }{ // Ok {probe.Success, false, true, "OK", "OK", nil}, // Ok {probe.Success, false, true, "OK", "OK", &fakeExitError{true, 0}}, // Ok - truncated output {probe.Success, false, true, elevenKilobyte, tenKilobyte, nil}, // Run returns error {probe.Unknown, true, true, "", "", fmt.Errorf("test error")}, // Unhealthy {probe.Failure, false, true, "Fail", "", &fakeExitError{true, 1}},
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 08:58:18 UTC 2024 - 3.8K bytes - Viewed (0) -
pkg/registry/core/componentstatus/rest_test.go
api "k8s.io/kubernetes/pkg/apis/core" "k8s.io/kubernetes/pkg/probe" ) type fakeHttpProber struct { result probe.Result body string err error } func (f *fakeHttpProber) Probe(*http.Request, time.Duration) (probe.Result, string, error) { return f.result, f.body, f.err } type testResponse struct { result probe.Result data string err error }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 13 08:10:29 UTC 2023 - 5.3K bytes - Viewed (0)