Versions in this module Expand all Collapse all v1 v1.16.3 Nov 9, 2022 Changes in this version + const EvictionRateLimiterBurst + const NodeEvictionPeriod + const NodeHealthUpdateRetry + const NodeUpdateChannelSize + const UpdateWorkerSize + type ActionFunc func(TimedValue) (bool, time.Duration) + type GetNodeFunc func(name string) (*v1.Node, error) + type GetPodFunc func(name, namespace string) (*v1.Pod, error) + type GetPodsByNodeNameFunc func(nodeName string) ([]v1.Pod, error) + type NoExecuteTaintManager struct + func NewNoExecuteTaintManager(c clientset.Interface, getPod GetPodFunc, getNode GetNodeFunc, ...) *NoExecuteTaintManager + func (tc *NoExecuteTaintManager) NodeUpdated(oldNode *v1.Node, newNode *v1.Node) + func (tc *NoExecuteTaintManager) PodUpdated(oldPod *v1.Pod, newPod *v1.Pod) + func (tc *NoExecuteTaintManager) Run(stopCh <-chan struct{}) + type RateLimitedTimedQueue struct + func NewRateLimitedTimedQueue(limiter flowcontrol.RateLimiter) *RateLimitedTimedQueue + func (q *RateLimitedTimedQueue) Add(value string, uid interface{}) bool + func (q *RateLimitedTimedQueue) Clear() + func (q *RateLimitedTimedQueue) Remove(value string) bool + func (q *RateLimitedTimedQueue) SwapLimiter(newQPS float32) + func (q *RateLimitedTimedQueue) Try(fn ActionFunc) + type TimedQueue []*TimedValue + func (h *TimedQueue) Pop() interface{} + func (h *TimedQueue) Push(x interface{}) + func (h TimedQueue) Len() int + func (h TimedQueue) Less(i, j int) bool + func (h TimedQueue) Swap(i, j int) + type TimedValue struct + AddedAt time.Time + ProcessAt time.Time + UID interface{} + Value string + type TimedWorker struct + CreatedAt time.Time + FireAt time.Time + Timer *time.Timer + WorkItem *WorkArgs + func CreateWorker(args *WorkArgs, createdAt time.Time, fireAt time.Time, ...) *TimedWorker + func (w *TimedWorker) Cancel() + type TimedWorkerQueue struct + func CreateWorkerQueue(f func(args *WorkArgs) error) *TimedWorkerQueue + func (q *TimedWorkerQueue) AddWork(args *WorkArgs, createdAt time.Time, fireAt time.Time) + func (q *TimedWorkerQueue) CancelWork(key string) bool + func (q *TimedWorkerQueue) GetWorkerUnsafe(key string) *TimedWorker + type UniqueQueue struct + func (q *UniqueQueue) Add(value TimedValue) bool + func (q *UniqueQueue) Clear() + func (q *UniqueQueue) Get() (TimedValue, bool) + func (q *UniqueQueue) Head() (TimedValue, bool) + func (q *UniqueQueue) Remove(value string) bool + func (q *UniqueQueue) RemoveFromQueue(value string) bool + func (q *UniqueQueue) Replace(value TimedValue) bool + type WorkArgs struct + NamespacedName types.NamespacedName + func NewWorkArgs(name, namespace string) *WorkArgs + func (w *WorkArgs) KeyFromWorkArgs() string