healthchecker

Documentation

Index

• type HealthChecker
  • func NewFakeChecker(healthy bool, settings map[string]int) HealthChecker
  • func NewHealthChecker(cfg *config.YurtHubConfiguration, tp transport.Interface, ...) (HealthChecker, error)
• type NodeLease
  • func NewNodeLease(client clientset.Interface, holderIdentity string, leaseDurationSeconds int32, ...) NodeLease

Types

type HealthChecker

type HealthChecker interface {
	IsHealthy(server *url.URL) bool
	Run()
}

HealthChecker is an interface for checking healthy stats of server

func NewFakeChecker

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

NewFakeChecker creates a fake checker

func NewHealthChecker

func NewHealthChecker(cfg *config.YurtHubConfiguration, tp transport.Interface, stopCh <-chan struct{}) (HealthChecker, error)

NewHealthChecker create an HealthChecker for servers

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