multicooker

Documentation

Index

• Constants
• type Evicter
  • func NewEvicter(client kubernetes.Interface, nodeName string, backoff string, minPodAge string) (*Evicter, error)
  • func (e *Evicter) CanEvict() bool
  • func (e *Evicter) EvictPod(evt PressureThresholdEvent) (bool, error)
• type PodCandidate
• type PodCandidateSet
  • func PodCandidateSetFromPodList(l *v1.PodList) PodCandidateSet
  • func (s PodCandidateSet) Len() int
  • func (s PodCandidateSet) Less(i, j int) bool
  • func (s PodCandidateSet) SelectPodForEviction(minPodAge time.Duration) *v1.Pod
  • func (s PodCandidateSet) Swap(i, j int)
• type PressureThresholdEvent
• type Tainter
  • func NewTainter(c kubernetes.Interface, nodeName string) (*Tainter, error)
  • func (t *Tainter) IsMulticookerDisabled() (bool, error)
  • func (t *Tainter) IsNodeTainted() (bool, error)
  • func (t *Tainter) TaintNode(evt PressureThresholdEvent) error
  • func (t *Tainter) UntaintNode(evt PressureThresholdEvent) error
• type Watcher
  • func NewWatcher(pressureThreshold float64, nodeName string) (*Watcher, error)
  • func (w *Watcher) CollectMetricsData(closeChan chan struct{}, useAvarage bool, metricChan chan [3]float64, ...)
  • func (w *Watcher) Run(closeChan chan struct{}, useAvarage bool, targetMetic int) (<-chan PressureThresholdEvent, <-chan error)
  • func (w *Watcher) SetAsHigh(high bool)

Constants

const ComponentName = "multicooker"

const TaintKey = "multicooker/load-exceeded"

Types

type Evicter

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

func NewEvicter

func NewEvicter(client kubernetes.Interface, nodeName string, backoff string, minPodAge string) (*Evicter, error)

func (*Evicter) CanEvict

func (e *Evicter) CanEvict() bool

func (*Evicter) EvictPod

func (e *Evicter) EvictPod(evt PressureThresholdEvent) (bool, error)

type PodCandidate

type PodCandidate struct {
	Pod   *v1.Pod
	Score int
}

type PodCandidateSet

type PodCandidateSet []PodCandidate

func PodCandidateSetFromPodList

func PodCandidateSetFromPodList(l *v1.PodList) PodCandidateSet

func (PodCandidateSet) Len

func (s PodCandidateSet) Len() int

func (PodCandidateSet) Less

func (s PodCandidateSet) Less(i, j int) bool

func (PodCandidateSet) SelectPodForEviction

func (s PodCandidateSet) SelectPodForEviction(minPodAge time.Duration) *v1.Pod

func (PodCandidateSet) Swap

func (s PodCandidateSet) Swap(i, j int)

type PressureThresholdEvent

type PressureThresholdEvent struct {
	Message         string
	MeticValue      float64
	IsCurrentlyHigh bool
}

type Tainter

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

func NewTainter

func NewTainter(c kubernetes.Interface, nodeName string) (*Tainter, error)

func (*Tainter) IsMulticookerDisabled

func (t *Tainter) IsMulticookerDisabled() (bool, error)

func (*Tainter) IsNodeTainted

func (t *Tainter) IsNodeTainted() (bool, error)

func (*Tainter) TaintNode

func (t *Tainter) TaintNode(evt PressureThresholdEvent) error

func (*Tainter) UntaintNode

func (t *Tainter) UntaintNode(evt PressureThresholdEvent) error

type Watcher

type Watcher struct {
	TickerInterval    time.Duration
	PressureThreshold float64
	// contains filtered or unexported fields
}

func NewWatcher

func NewWatcher(pressureThreshold float64, nodeName string) (*Watcher, error)

func (*Watcher) CollectMetricsData

func (w *Watcher) CollectMetricsData(closeChan chan struct{}, useAvarage bool, metricChan chan [3]float64, errorChan chan error)

func (*Watcher) Run

func (w *Watcher) Run(closeChan chan struct{}, useAvarage bool, targetMetic int) (<-chan PressureThresholdEvent, <-chan error)

func (*Watcher) SetAsHigh

func (w *Watcher) SetAsHigh(high bool)