healthcheck

Documentation

Index

• type HealthCheckController
  • func NewCloudAPIHealthChecker(podLister registry.PodLister, cloudClient cloud.CloudClient, ...) *HealthCheckController
  • func NewStatusHealthChecker(podLister registry.PodLister, nodeLister registry.NodeLister, ...) *HealthCheckController
  • func (c *HealthCheckController) ClearLastStatusTime(podName string)
  • func (c *HealthCheckController) LastStatusTime(podName string) (time.Time, bool)
  • func (c *HealthCheckController) SetLastStatusTime(podName string)
  • func (c *HealthCheckController) Start()
  • func (c *HealthCheckController) TerminatePodsChan() <-chan *api.Pod

Types

type HealthCheckController

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

func NewCloudAPIHealthChecker

func NewCloudAPIHealthChecker(
	podLister registry.PodLister,
	cloudClient cloud.CloudClient,
	checkInterval time.Duration,
	unhealthyTimeout time.Duration) *HealthCheckController

func NewStatusHealthChecker

func NewStatusHealthChecker(
	podLister registry.PodLister,
	nodeLister registry.NodeLister,
	nodeClientFactory nodeclient.ItzoClientFactoryer,
	checkInterval time.Duration,
	unhealthyTimeout time.Duration) *HealthCheckController

func (*HealthCheckController) ClearLastStatusTime

func (c *HealthCheckController) ClearLastStatusTime(podName string)

func (*HealthCheckController) LastStatusTime

func (c *HealthCheckController) LastStatusTime(podName string) (time.Time, bool)

func (*HealthCheckController) SetLastStatusTime

func (c *HealthCheckController) SetLastStatusTime(podName string)

func (*HealthCheckController) Start

func (c *HealthCheckController) Start()

func (*HealthCheckController) TerminatePodsChan

func (c *HealthCheckController) TerminatePodsChan() <-chan *api.Pod