healthcheck

Documentation

Index

• func SendHeartBeat(channel chan<- *ControllerHeartbeat, controller string)
• type ControllerHeartbeat
• type HealthController
  • func NewHealthController(config *options.KubeRouterConfig) (*HealthController, error)
  • func (hc *HealthController) CheckHealth() bool
  • func (hc *HealthController) HandleHeartbeat(beat *ControllerHeartbeat)
  • func (hc *HealthController) Handler(w http.ResponseWriter, req *http.Request)
  • func (hc *HealthController) RunCheck(healthChan <-chan *ControllerHeartbeat, stopCh <-chan struct{}, ...) error
  • func (hc *HealthController) RunServer(stopCh <-chan struct{}, wg *sync.WaitGroup) error
  • func (hc *HealthController) SetAlive()
• type HealthStats

Functions

func SendHeartBeat

func SendHeartBeat(channel chan<- *ControllerHeartbeat, controller string)

SendHeartBeat sends a heartbeat on the passed channel

Types

type ControllerHeartbeat

type ControllerHeartbeat struct {
	Component     string
	LastHeartBeat time.Time
}

ControllerHeartbeat is the structure to hold the heartbeats sent by controllers

type HealthController

type HealthController struct {
	HealthPort  uint16
	HTTPEnabled bool
	Status      HealthStats
	Config      *options.KubeRouterConfig
}

HealthController reports the health of the controller loops as a http endpoint

func NewHealthController

func NewHealthController(config *options.KubeRouterConfig) (*HealthController, error)

NewHealthController creates a new health controller and returns a reference to it

func (*HealthController) CheckHealth

func (hc *HealthController) CheckHealth() bool

CheckHealth evaluates the time since last heartbeat to decide if the controller is running or not

func (*HealthController) HandleHeartbeat

func (hc *HealthController) HandleHeartbeat(beat *ControllerHeartbeat)

HandleHeartbeat handles received heartbeats on the health channel

func (*HealthController) Handler

func (hc *HealthController) Handler(w http.ResponseWriter, req *http.Request)

Handler writes HTTP responses to the health path

func (*HealthController) RunCheck

func (hc *HealthController) RunCheck(healthChan <-chan *ControllerHeartbeat, stopCh <-chan struct{}, wg *sync.WaitGroup) error

RunCheck starts the HealthController's check

func (*HealthController) RunServer

func (hc *HealthController) RunServer(stopCh <-chan struct{}, wg *sync.WaitGroup) error

RunServer starts the HealthController's server

func (*HealthController) SetAlive

func (hc *HealthController) SetAlive()

type HealthStats

type HealthStats struct {
	sync.Mutex
	Healthy                           bool
	MetricsControllerAlive            time.Time
	NetworkPolicyControllerAlive      time.Time
	NetworkPolicyControllerAliveTTL   time.Duration
	NetworkRoutingControllerAlive     time.Time
	NetworkRoutingControllerAliveTTL  time.Duration
	NetworkServicesControllerAlive    time.Time
	NetworkServicesControllerAliveTTL time.Duration
}

HealthStats is holds the latest heartbeats