Documentation ¶
Index ¶
Constants ¶
View Source
const ComponentName = "pressurecooker"
View Source
const TaintKey = "pressurecooker/load-exceeded"
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type PodCandidate ¶
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 Tainter ¶
type Tainter struct {
// contains filtered or unexported fields
}
func NewTainter ¶
func NewTainter(c kubernetes.Interface, nodeName string) (*Tainter, error)
func (*Tainter) IsNodeTainted ¶
func (*Tainter) IsPressurecookerDisabled ¶ added in v0.2.4
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 (*Watcher) Run ¶
func (w *Watcher) Run(closeChan chan struct{}) (<-chan PressureThresholdEvent, <-chan PressureThresholdEvent, <-chan error)
Click to show internal directories.
Click to hide internal directories.