Documentation
¶
Index ¶
- Constants
- func Add(mgr manager.Manager) error
- func Match(ds *ketiv1.DaemonSet, history *ketiv1.ControllerRevision) (bool, error)
- func NewPod(ds *ketiv1.DaemonSet, nodeName string) *ketiv1.Pod
- func Predicates(pod *ketiv1.Pod, nodeInfo *schedulernodeinfo.NodeInfo) (bool, []predicates.PredicateFailureReason, error)
- type ReconcileDaemonSet
Constants ¶
const ( // BurstReplicas is a rate limiter for booting pods on a lot of pods. // The value of 250 is chosen b/c values that are too high can cause registry DoS issues. BurstReplicas = 250 // StatusUpdateRetries limits the number of retries if sending a status update to API server fails. StatusUpdateRetries = 1 // BackoffGCInterval is the time that has to pass before next iteration of backoff GC is run BackoffGCInterval = 1 * time.Minute )
const ( // SelectingAllReason is added to an event when a DaemonSet selects all Pods. SelectingAllReason = "SelectingAll" // FailedPlacementReason is added to an event when a DaemonSet can't schedule a Pod to a specified node. FailedPlacementReason = "FailedPlacement" // FailedDaemonPodReason is added to an event when the status of a Pod of a DaemonSet is 'Failed'. FailedDaemonPodReason = "FailedDaemonPod" )
const ( TypeLabel = "keti.checkpoint.type" NameLabel = "keti.checkpoint.name" )
Variables ¶
This section is empty.
Functions ¶
func Add ¶
Add creates a new DaemonSet Controller and adds it to the Manager. The Manager will set fields on the Controller and Start it when the Manager is Started.
func Match ¶
Match check if the given DaemonSet's template matches the template stored in the given history.
func Predicates ¶
func Predicates(pod *ketiv1.Pod, nodeInfo *schedulernodeinfo.NodeInfo) (bool, []predicates.PredicateFailureReason, error)
Predicates checks if a DaemonSet's pod can be scheduled on a node using GeneralPredicates and PodToleratesNodeTaints predicate
Types ¶
type ReconcileDaemonSet ¶
type ReconcileDaemonSet struct {
KetiClient clientset.KetiV1Interface
KubeClient kubeclient.Interface
// contains filtered or unexported fields
}
ReconcileDaemonSet reconciles a DaemonSet object
func (*ReconcileDaemonSet) Reconcile ¶
Reconcile reads that state of the cluster for a DaemonSet object and makes changes based on the state read and what is in the DaemonSet.Spec TODO(user): Modify this Reconcile function to implement your Controller logic. This example creates a Pod as an example Note: The Controller will requeue the Request to be processed again if the returned error is non-nil or Result.Requeue is true, otherwise upon completion it will remove the work from the queue.
Source Files
Directories