scheduler

Aug 10, 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(ctx context.Context, c clientset.Interface, getPod GetPodFunc, ...) *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(ctx context.Context)

+ 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 clock.Timer

+ WorkItem *WorkArgs

+ func (w *TimedWorker) Cancel()

+ type TimedWorkerQueue struct

+ func CreateWorkerQueue(f func(ctx context.Context, args *WorkArgs) error) *TimedWorkerQueue

+ func (q *TimedWorkerQueue) AddWork(ctx context.Context, 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