loadwatcher

Documentation

Index

• Constants
• type Evicter
  • func NewEvicter(client kubernetes.Interface, threshold int, nodeName string, backoff string) (*Evicter, error)
  • func (e *Evicter) CanEvict() bool
  • func (e *Evicter) EvictPod(evt LoadThresholdEvent) (bool, error)
• type LoadThresholdEvent
• 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() *v1.Pod
  • func (s PodCandidateSet) Swap(i, j int)
• type Tainter
  • func NewTainter(c kubernetes.Interface, nodeName string) (*Tainter, error)
  • func (t *Tainter) IsNodeTainted() (bool, error)
  • func (t *Tainter) TaintNode(evt LoadThresholdEvent) error
  • func (t *Tainter) UntaintNode(evt LoadThresholdEvent) error
• type Watcher
  • func NewWatcher(loadThreshold int) (*Watcher, error)
  • func (w *Watcher) Run(closeChan chan struct{}) (<-chan LoadThresholdEvent, <-chan LoadThresholdEvent, <-chan error)
  • func (w *Watcher) SetAsHigh(high bool)

Constants

const ComponentName = "loadwatcher"

const TaintKey = "loadwatcher.mittwald.systems/load-exceeded"

Types

type Evicter

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

func NewEvicter

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

func (*Evicter) CanEvict

func (e *Evicter) CanEvict() bool

func (*Evicter) EvictPod

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

type LoadThresholdEvent

type LoadThresholdEvent struct {
	LoadThreshold float64
	Load5         float64
	Load15        float64
}

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() *v1.Pod

func (PodCandidateSet) Swap

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

type Tainter

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

func NewTainter

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

func (*Tainter) IsNodeTainted

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

func (*Tainter) TaintNode

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

func (*Tainter) UntaintNode

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

type Watcher

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

func NewWatcher

func NewWatcher(loadThreshold int) (*Watcher, error)

func (*Watcher) Run

func (w *Watcher) Run(closeChan chan struct{}) (<-chan LoadThresholdEvent, <-chan LoadThresholdEvent, <-chan error)

func (*Watcher) SetAsHigh

func (w *Watcher) SetAsHigh(high bool)