health

package
v0.9.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Sep 16, 2019 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func HTTPProbe added in v0.8.0

func HTTPProbe(config HTTPProbeConfigOptions) error

HTTPProbe checks that HTTP connection can be established to the address.

func IsHTTPProbeReady added in v0.8.0

func IsHTTPProbeReady(res *http.Response) bool

IsHTTPProbeReady checks whether we received a successful Response

func TCPProbe

func TCPProbe(config TCPProbeConfigOptions) error

TCPProbe checks that a TCP socket to the address can be opened. Did not reuse k8s.io/kubernetes/pkg/probe/tcp to not create a dependency on klog.

Types

type HTTPProbeConfigOptions added in v0.8.0

type HTTPProbeConfigOptions struct {
	Timeout time.Duration
	*corev1.HTTPGetAction
	KubeMajor string
	KubeMinor string
}

HTTPProbeConfigOptions holds the HTTP probe config options

type State

type State struct {
	// contains filtered or unexported fields
}

State holds state about the current healthiness of the component.

func (*State) DrainHandler added in v0.5.0

func (h *State) DrainHandler() func(_ http.ResponseWriter, _ *http.Request)

DrainHandler constructs a handler that waits until the proxy server is shut down.

func (*State) HealthHandler

func (h *State) HealthHandler(prober func() bool, isAggressive bool) func(w http.ResponseWriter, r *http.Request)

HealthHandler constructs a handler that returns the current state of the health server. If isAggressive is false and prober has succeeded previously, the function return success without probing user-container again (until shutdown).

func (*State) IsAlive

func (h *State) IsAlive() bool

IsAlive returns whether or not the health server is in a known working state currently.

func (*State) IsShuttingDown

func (h *State) IsShuttingDown() bool

IsShuttingDown returns whether or not the health server is currently shutting down.

func (*State) Shutdown added in v0.5.0

func (h *State) Shutdown(drain func())

Shutdown marks the proxy server as no ready and begins its shutdown process. This results in unblocking any connections waiting for drain.

type TCPProbeConfigOptions added in v0.8.0

type TCPProbeConfigOptions struct {
	SocketTimeout time.Duration
	Address       string
}

TCPProbeConfigOptions holds the TCP probe config options

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL