istio: istio.io/istio/pkg/istio-agent/health Index | Files

package health

import "istio.io/istio/pkg/istio-agent/health"

Index

Package Files

health_check.go health_probers.go

type AggregateProber Uses

❖
type AggregateProber struct {
    Probes []Prober
}

func (AggregateProber) Probe Uses

❖
func (a AggregateProber) Probe(timeout time.Duration) (ProbeResult, error)

type EnvoyProber Uses

❖
type EnvoyProber struct {
    Config ready.Prober
}

func (EnvoyProber) Probe Uses

❖
func (a EnvoyProber) Probe(time.Duration) (ProbeResult, error)

type ExecProber Uses

❖
type ExecProber struct {
    Config *v1alpha3.ExecHealthCheckConfig
}

func (*ExecProber) Probe Uses

❖
func (e *ExecProber) Probe(timeout time.Duration) (ProbeResult, error)

type HTTPProber Uses

❖
type HTTPProber struct {
    Config    *v1alpha3.HTTPHealthCheckConfig
    Transport *http.Transport
}

func NewHTTPProber Uses

❖
func NewHTTPProber(cfg *v1alpha3.HTTPHealthCheckConfig) *HTTPProber

func (*HTTPProber) Probe Uses

❖
func (h *HTTPProber) Probe(timeout time.Duration) (ProbeResult, error)

HttpProber_Probe will return whether or not the target is healthy (true -> healthy) 

by making an HTTP Get response.

type ProbeEvent Uses

❖
type ProbeEvent struct {
    Healthy          bool
    UnhealthyStatus  int32
    UnhealthyMessage string
}

type ProbeResult Uses

❖
type ProbeResult string
❖
const (
    Healthy   ProbeResult = "HEALTHY"
    Unhealthy ProbeResult = "UNHEALTHY"
    Unknown   ProbeResult = "UNKNOWN"
)

func (*ProbeResult) IsHealthy Uses

❖
func (p *ProbeResult) IsHealthy() bool

type Prober Uses

❖
type Prober interface {
    // Probe will healthcheck and return whether or not the target is healthy.
    // If an error returned is not nil, it is assumed that the process could
    // not complete, and Probe() was unable to determine whether or not the
    // target was healthy.
    Probe(timeout time.Duration) (ProbeResult, error)
}

type TCPProber Uses

❖
type TCPProber struct {
    Config *v1alpha3.TCPHealthCheckConfig
}

func (*TCPProber) Probe Uses

❖
func (t *TCPProber) Probe(timeout time.Duration) (ProbeResult, error)

type WorkloadHealthChecker Uses

❖
type WorkloadHealthChecker struct {
    // contains filtered or unexported fields
}

func NewWorkloadHealthChecker Uses

❖
func NewWorkloadHealthChecker(cfg *v1alpha3.ReadinessProbe, envoyProbe ready.Prober) *WorkloadHealthChecker

func (*WorkloadHealthChecker) PerformApplicationHealthCheck Uses

❖
func (w *WorkloadHealthChecker) PerformApplicationHealthCheck(callback func(*ProbeEvent), quit chan struct{})

PerformApplicationHealthCheck Performs the application-provided configuration health check. Instead of a heartbeat-based health checks, we only send on a health state change, and this is determined by the success & failure threshold provided by the user.

Package health imports 15 packages (graph) and is imported by 2 packages. Updated 2021-01-27. Refresh now. Tools for package owners.