healthchecker

Documentation

Index

• Constants
• type BackendProber
• type HealthChecker
  • func NewCoordinatorHealthChecker(cfg *config.YurtHubConfiguration, checkerClient kubernetes.Interface, ...) (HealthChecker, error)
• type MultipleBackendsHealthChecker
  • func NewCloudAPIServerHealthChecker(cfg *config.YurtHubConfiguration, ...) (MultipleBackendsHealthChecker, error)
  • func NewFakeChecker(healthy bool, settings map[string]int) MultipleBackendsHealthChecker
• type NodeLease
  • func NewNodeLease(client clientset.Interface, holderIdentity string, leaseDurationSeconds int32, ...) NodeLease

Constants

const (
	ProbePhaseInit   = "init"
	ProbePhaseNormal = "normal"
)

const (
	DelegateHeartBeat = "openyurt.io/delegate-heartbeat"
)

Types

type BackendProber

type BackendProber interface {
	// RenewKubeletLeaseTime is used for notifying whether kubelet stopped or not,
	// when kubelet lease renew time is stopped to report, health checker will stop check
	// the healthy status of remote server and mark remote server as unhealthy.
	RenewKubeletLeaseTime(time time.Time)
	// Probe send one heartbeat to backend and should be executed by caller in interval
	Probe(phase string) bool
	IsHealthy() bool
}

BackendProber is used to send heartbeat to backend and verify backend is healthy or not

type HealthChecker

type HealthChecker interface {
	// RenewKubeletLeaseTime is used for notifying whether kubelet stopped or not,
	// when kubelet lease renew time is stopped to report, health checker will stop check
	// the healthy status of remote server and mark remote server as unhealthy.
	RenewKubeletLeaseTime()
	IsHealthy() bool
}

HealthChecker is an interface for checking healthy status of one server

func NewCoordinatorHealthChecker

func NewCoordinatorHealthChecker(cfg *config.YurtHubConfiguration, checkerClient kubernetes.Interface, cloudServerHealthChecker HealthChecker, stopCh <-chan struct{}) (HealthChecker, error)

NewCoordinatorHealthChecker returns a health checker for verifying yurt coordinator status.

type MultipleBackendsHealthChecker

type MultipleBackendsHealthChecker interface {
	HealthChecker
	BackendHealthyStatus(server *url.URL) bool
	PickHealthyServer() (*url.URL, error)
}

MultipleBackendsHealthChecker is used for checking healthy status of multiple servers, like there are several kube-apiserver instances on the cloud for high availability.

func NewCloudAPIServerHealthChecker

func NewCloudAPIServerHealthChecker(cfg *config.YurtHubConfiguration, healthCheckerClients map[string]kubernetes.Interface, stopCh <-chan struct{}) (MultipleBackendsHealthChecker, error)

NewCloudAPIServerHealthChecker returns a health checker for verifying cloud kube-apiserver status.

func NewFakeChecker

func NewFakeChecker(healthy bool, settings map[string]int) MultipleBackendsHealthChecker

NewFakeChecker creates a fake checker

type NodeLease

type NodeLease interface {
	Update(base *coordinationv1.Lease) (*coordinationv1.Lease, error)
}

func NewNodeLease

func NewNodeLease(client clientset.Interface, holderIdentity string, leaseDurationSeconds int32, failedRetry int) NodeLease