pressurecooker

Jun 4, 2020

Changes in this version

type Tainter

+ func (t *Tainter) IsPressurecookerDisabled() (bool, error)

May 29, 2020

Changes in this version

+ const ComponentName

+ const TaintKey

+ type Evicter struct

+ func NewEvicter(client kubernetes.Interface, threshold float64, nodeName string, ...) (*Evicter, error)

+ func (e *Evicter) CanEvict() bool

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

+ type PodCandidate struct

+ Pod *v1.Pod

+ Score int

+ type PodCandidateSet []PodCandidate

+ 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 procfs.PSILine

+ type Tainter struct

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

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

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

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

+ type Watcher struct

+ PressureThreshold float64

+ TickerInterval time.Duration

+ func NewWatcher(pressureThreshold float64) (*Watcher, error)

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

+ func (w *Watcher) SetAsHigh(high bool)