node

Documentation

Index

• Constants
• type ServicesStateMonitor
  • func NewNodeServicesStateMonitor(client *k8s.KubeClient, logger *logrus.Logger) *ServicesStateMonitor
  • func (n *ServicesStateMonitor) GetReadyPods() []string
  • func (n *ServicesStateMonitor) GetUnreadyPods() []string
  • func (n *ServicesStateMonitor) Run()
  • func (n *ServicesStateMonitor) UpdateNodeHealthCache()

Constants

const (
	// when initializing or unable to detect state
	Unknown = 0
	// pod is ready
	Ready = 1
	// pod is in unready state for > X seconds, but < Y seconds
	Unready = 2
	// pod is in unready state for > Y seconds
	PermanentDown = 3
)

constants for state monitoring

const (
	UnreadyTimeout       = 60
	PermanentDownTimeout = 120
	SleepBeforeNextPoll  = 30
	// StartupProtectionMultiplier will be applied to Timeouts if POD is under startup protection
	StartupProtectionMultiplier = 5
)

timeout constant seconds

Types

type ServicesStateMonitor

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

ServicesStateMonitor contains methods to get Node service health state

func NewNodeServicesStateMonitor

func NewNodeServicesStateMonitor(client *k8s.KubeClient, logger *logrus.Logger) *ServicesStateMonitor

NewNodeServicesStateMonitor instantiates health monitor

func (*ServicesStateMonitor) GetReadyPods

func (n *ServicesStateMonitor) GetReadyPods() []string

GetReadyPods obtains list of Ready pods. Blocking for read

func (*ServicesStateMonitor) GetUnreadyPods

func (n *ServicesStateMonitor) GetUnreadyPods() []string

GetUnreadyPods obtains list of Unready pods. Blocking for read

func (*ServicesStateMonitor) Run

func (n *ServicesStateMonitor) Run()

Run inits map node id -> health

func (*ServicesStateMonitor) UpdateNodeHealthCache

func (n *ServicesStateMonitor) UpdateNodeHealthCache()

UpdateNodeHealthCache check if node service pods are ready and update nodeHealthMap