Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 359 for prober (0.46 sec)

  1. pkg/kubelet/prober/prober.go

    	httpprobe "k8s.io/kubernetes/pkg/probe/http"
    	tcpprobe "k8s.io/kubernetes/pkg/probe/tcp"
    	"k8s.io/utils/exec"
    
    	"k8s.io/klog/v2"
    )
    
    const maxProbeRetries = 3
    
    // Prober helps to check the liveness/readiness/startup of a container.
    type prober struct {
    	exec   execprobe.Prober
    	http   httpprobe.Prober
    	tcp    tcpprobe.Prober
    	grpc   grpcprobe.Prober
    	runner kubecontainer.CommandRunner
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Feb 16 10:50:13 UTC 2024
    - 8.7K bytes
    - Viewed (0)
  2. pkg/istio-agent/health/health_check.go

    		prober = &TCPProber{Config: healthCheckMethod.TcpSocket}
    	case *v1alpha3.ReadinessProbe_Exec:
    		prober = &ExecProber{Config: healthCheckMethod.Exec}
    	default:
    		prober = nil
    	}
    
    	probers := []Prober{}
    	if envoyProbe != nil {
    		probers = append(probers, &EnvoyProber{envoyProbe})
    	}
    	probers = append(probers, prober)
    	return &WorkloadHealthChecker{
    		config: applicationHealthCheckConfig{
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Jul 21 03:06:44 UTC 2021
    - 5.7K bytes
    - Viewed (0)
  3. pkg/volume/flexvolume/probe.go

    	if err := prober.createPluginDir(); err != nil {
    		return err
    	}
    	if err := prober.initWatcher(); err != nil {
    		return err
    	}
    
    	return nil
    }
    
    // If probeAllNeeded is true, probe all pluginDir
    // else probe events in eventsMap
    func (prober *flexVolumeProber) Probe() (events []volume.ProbeEvent, err error) {
    	if prober.probeAllNeeded {
    		prober.testAndSetProbeAllNeeded(false)
    		return prober.probeAll()
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Nov 28 11:14:00 UTC 2023
    - 9K bytes
    - Viewed (0)
  4. pkg/registry/core/componentstatus/validator.go

    	req, err := httpprober.NewProbeRequest(url, nil)
    	if err != nil {
    		return probe.Unknown, "", fmt.Errorf("failed to construct probe request: %w", err)
    	}
    	result, data, err := server.Prober.Probe(req, probeTimeOut)
    
    	if err != nil {
    		return probe.Unknown, "", err
    	}
    	if result == probe.Failure {
    		return probe.Failure, data, err
    	}
    	if server.Validate != nil {
    		if err := server.Validate([]byte(data)); err != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Jul 20 13:08:41 UTC 2023
    - 2.9K bytes
    - Viewed (0)
  5. pkg/kube/inject/app_probe.go

    // kubeProbeToInternalProber converts a Kubernetes Probe to an Istio internal Prober
    func kubeProbeToInternalProber(probe *corev1.Probe) *Prober {
    	if probe == nil {
    		return nil
    	}
    
    	if probe.HTTPGet != nil {
    		return &Prober{
    			HTTPGet:        probe.HTTPGet,
    			TimeoutSeconds: probe.TimeoutSeconds,
    		}
    	}
    
    	if probe.TCPSocket != nil {
    		return &Prober{
    			TCPSocket:      probe.TCPSocket,
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Aug 04 15:06:24 UTC 2023
    - 8.4K bytes
    - Viewed (0)
  6. pkg/kubelet/prober/prober_test.go

    		},
    		{ // No handler
    			probe:          &v1.Probe{},
    			expectError:    true,
    			expectedResult: results.Failure,
    		},
    		{ // Probe fails
    			probe:          execProbe,
    			execResult:     probe.Failure,
    			expectedResult: results.Failure,
    		},
    		{ // Probe succeeds
    			probe:          execProbe,
    			execResult:     probe.Success,
    			expectedResult: results.Success,
    		},
    		{ // Probe result is warning
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon May 01 07:17:35 UTC 2023
    - 9.7K bytes
    - Viewed (0)
  7. pkg/probe/exec/exec.go

    	"k8s.io/kubernetes/pkg/probe"
    
    	"k8s.io/klog/v2"
    	"k8s.io/utils/exec"
    )
    
    const (
    	maxReadLength = 10 * 1 << 10 // 10KB
    )
    
    // New creates a Prober.
    func New() Prober {
    	return execProber{}
    }
    
    // Prober is an interface defining the Probe object for container readiness/liveness checks.
    type Prober interface {
    	Probe(e exec.Cmd) (probe.Result, string, error)
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 14 08:58:18 UTC 2024
    - 2.2K bytes
    - Viewed (0)
  8. pkg/istio-agent/health/health_probers.go

    }
    
    type EnvoyProber struct {
    	Config ready.Prober
    }
    
    var _ Prober = &EnvoyProber{}
    
    func (a EnvoyProber) Probe(time.Duration) (ProbeResult, error) {
    	if err := a.Config.Check(); err != nil {
    		return Unhealthy, err
    	}
    	return Healthy, nil
    }
    
    type AggregateProber struct {
    	Probes []Prober
    }
    
    var _ Prober = &AggregateProber{}
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue May 23 17:08:31 UTC 2023
    - 5.7K bytes
    - Viewed (0)
  9. pkg/probe/tcp/tcp.go

    import (
    	"net"
    	"strconv"
    	"time"
    
    	"k8s.io/kubernetes/pkg/probe"
    
    	"k8s.io/klog/v2"
    )
    
    // New creates Prober.
    func New() Prober {
    	return tcpProber{}
    }
    
    // Prober is an interface that defines the Probe function for doing TCP readiness/liveness checks.
    type Prober interface {
    	Probe(host string, port int, timeout time.Duration) (probe.Result, string, error)
    }
    
    type tcpProber struct{}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sun Jan 22 16:57:41 UTC 2023
    - 1.9K bytes
    - Viewed (0)
  10. pkg/probe/http/http.go

    	return httpProber{transport, followNonLocalRedirects}
    }
    
    // Prober is an interface that defines the Probe function for doing HTTP readiness/liveness checks.
    type Prober interface {
    	Probe(req *http.Request, timeout time.Duration) (probe.Result, string, error)
    }
    
    type httpProber struct {
    	transport               *http.Transport
    	followNonLocalRedirects bool
    }
    
    // Probe returns a ProbeRunner capable of running an HTTP check.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Feb 10 00:37:32 UTC 2023
    - 5K bytes
    - Viewed (0)
Back to top