health

Documentation

Index

• type ReadinessChecker
  • func NewReadinessChecker(clientset kubecli.KubevirtClient, host string, config *config.ClusterConfig) *ReadinessChecker
  • func (l *ReadinessChecker) HeartBeat(interval time.Duration, maxErrorsPerInterval uint64, stopCh chan struct{})

Types

type ReadinessChecker

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

func NewReadinessChecker

func NewReadinessChecker(clientset kubecli.KubevirtClient, host string, config *config.ClusterConfig) *ReadinessChecker

func (*ReadinessChecker) HeartBeat

func (l *ReadinessChecker) HeartBeat(interval time.Duration, maxErrorsPerInterval uint64, stopCh chan struct{})

HeartBeat take a heartbeat inverval, a maximum of non-userfacing errors which are allowed to happen and a stop channel to stop the heartbeat updates. It periodically performs some health checks and updates the kubevirt.io/schedulable according to its checks. Further it sets a timestamp on the node so that cluster components can see when it last updated the node.