health

Documentation

Index

• type Checker
  • func NewChecker(pp *PortProbe, ec *EndpointClient) *Checker
  • func NewCheckerK8S(pp *PortProbe, k8s *KubernetesClient, ec *EndpointClient) *Checker
  • func (hc *Checker) GetHealth(ctx context.Context) float64
• type EndpointClient
  • func NewEndpointClient(timeout time.Duration) *EndpointClient
• type KubernetesClient
  • func MustNewKubernetesClient(url *url.URL, pod, node, namespace, auth string) *KubernetesClient
• type PortProbe
  • func NewPortProbe(services map[string][]string) *PortProbe

Types

type Checker

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

Checker checks the health of a local experiment instance.

func NewChecker

func NewChecker(pp *PortProbe, ec *EndpointClient) *Checker

NewChecker creates a new Checker.

func NewCheckerK8S

func NewCheckerK8S(pp *PortProbe, k8s *KubernetesClient, ec *EndpointClient) *Checker

NewCheckerK8S creates a new Checker for Kubernetes deployments.

func (*Checker) GetHealth

func (hc *Checker) GetHealth(ctx context.Context) float64

GetHealth combines a set of health checks into a single score.

type EndpointClient

type EndpointClient struct {
	http.Client
}

EndpointClient is an http client to check the local /health endpoint.

func NewEndpointClient

func NewEndpointClient(timeout time.Duration) *EndpointClient

NewEndpointClient returns a new *EndpointClient with the specified request timeout.

type KubernetesClient

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

KubernetesClient manages requests to the Kubernetes API server.

func MustNewKubernetesClient

func MustNewKubernetesClient(url *url.URL, pod, node, namespace, auth string) *KubernetesClient

MustNewKubernetesClient creates a new KubenernetesClient instance. If the client cannot be instantiated, the function will exit.

type PortProbe

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

PortProbe checks whether a set of ports are open.

func NewPortProbe

func NewPortProbe(services map[string][]string) *PortProbe

NewPortProbe creates a new PortProbe.