# Packages
No description provided by the author
# Functions
CreateWorker creates a TimedWorker that will execute `f` not earlier than `fireAt`.
CreateWorkerQueue creates a new TimedWorkerQueue for workers that will execute given function `f`.
NewCIDRRangeAllocator returns a CIDRAllocator to allocate CIDR for node Caller must ensure subNetMaskSize is not less than cluster CIDR mask size.
NewNodeController returns a new node controller to sync instances from cloudprovider.
NewNoExecuteTaintManager creates a new NoExecuteTaintManager that will use passed clientset to communicate with the API server.
Creates new queue which will use given RateLimiter to oversee execution.
NewWorkArgs is a helper function to create new `WorkArgs`.
No description provided by the author
# Constants
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
# Variables
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
# Structs
No description provided by the author
NoExecuteTaint manager listens to Taint/Toleration changes and is resposible for removing Pods from Nodes tainted with NoExecute Taints.
RateLimitedTimedQueue is a unique item priority queue ordered by the expected next time of execution.
TimedValue is a value that should be processed at a designated time.
TimedWorker is a responsible for executing a function no earlier than at FireAt time.
TimedWorkerQueue keeps a set of TimedWorkers that still wait for execution.
A FIFO queue which additionally guarantees that any element can be added only once until it is removed.
WorkArgs keeps arguments that will be passed to tha function executed by the worker.
# Interfaces
CIDRAllocator is an interface implemented by things that know how to allocate/occupy/recycle CIDR for nodes.
# Type aliases
ActionFunc takes a timed value and returns false if the item must be retried, with an optional time.Duration if some minimum wait interval should be used.
TimedQueue is a priority heap where the lowest ProcessAt is at the front of the queue.