healthchecker

Documentation

Index

• type HealthChecker
• type HealthCheckerImpl
  • func NewHealthChecker(cluster *resource.Cluster, clientset *kubernetes.Clientset, ...) *HealthCheckerImpl
  • func (hc *HealthCheckerImpl) Probe(ctx context.Context, l logr.Logger, logSuffix string, nodeID int) error

Types

type HealthChecker

type HealthChecker interface {
	Probe(ctx context.Context, l logr.Logger, logSuffix string, partition int) error
}

HealthChecker interface

type HealthCheckerImpl

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

HealthCheckerImpl struct

func NewHealthChecker

func NewHealthChecker(cluster *resource.Cluster, clientset *kubernetes.Clientset, scheme *runtime.Scheme, config *rest.Config) *HealthCheckerImpl

NewHealthChecker ctor

func (*HealthCheckerImpl) Probe

func (hc *HealthCheckerImpl) Probe(ctx context.Context, l logr.Logger, logSuffix string, nodeID int) error

Probe will check the ranges_underreplicated metric for value 0 on all pods after the resart of a pod, before continue the rolling update of the next pod