Documentation
¶
Overview ¶
Package extendeddaemonsetreplicaset contains ExtendedDaemonsetReplicaset controller logic.
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func FilterPodsByNode ¶
func FilterPodsByNode(podsByNodeName map[string][]*corev1.Pod, nodesMap map[string]*strategy.NodeItem) (map[*strategy.NodeItem]*corev1.Pod, []*corev1.Pod)
FilterPodsByNode if several Pods are listed for the same Node select "best" Pod one, and add other pod to the deletion pod slice.
Types ¶
type Reconciler ¶
type Reconciler struct {
// contains filtered or unexported fields
}
Reconciler is the internal reconciler for ExtendedDaemonSetReplicaSet.
func NewReconciler ¶
func NewReconciler(options ReconcilerOptions, client client.Client, scheme *runtime.Scheme, log logr.Logger, recorder record.EventRecorder) (*Reconciler, error)
NewReconciler returns a reconciler for DatadogAgent.
func (*Reconciler) FilterAndMapPodsByNode ¶ added in v0.6.0
func (r *Reconciler) FilterAndMapPodsByNode( logger logr.Logger, replicaset *datadoghqv1alpha1.ExtendedDaemonSetReplicaSet, nodeList *strategy.NodeList, podList *corev1.PodList, ignoreNodes []string, ) ( nodesByName map[string]*strategy.NodeItem, podsByNode map[*strategy.NodeItem]*corev1.Pod, podsToDelete, unscheduledPods []*corev1.Pod, )
FilterAndMapPodsByNode is used to map pods by associated node. It also returns the list of pods that should be deleted (not needed anymore), and pods that are not scheduled yet (created but not scheduled).
func (*Reconciler) Reconcile ¶
func (r *Reconciler) Reconcile(ctx context.Context, request reconcile.Request) (reconcile.Result, error)
Reconcile reads that state of the cluster for a ExtendedDaemonSetReplicaSet object and makes changes based on the state read and what is in the ExtendedDaemonSetReplicaSet.Spec.
type ReconcilerOptions ¶
type ReconcilerOptions struct {
IsNodeAffinitySupported bool
}
ReconcilerOptions provides options read from command line.
Source Files
Directories
¶
| Path | Synopsis |
|---|---|
|
Package conditions contains ExtendedDaemonSetReplicaSet Conditions helper functions.
|
Package conditions contains ExtendedDaemonSetReplicaSet Conditions helper functions. |
|
Package scheduler contains helper function around Daemonset pod scheduling.
|
Package scheduler contains helper function around Daemonset pod scheduling. |
|
Package strategy contains the different ExtendedDaemonsetReplicaset pod's strategies: * canary * rolling-update * unknow
|
Package strategy contains the different ExtendedDaemonsetReplicaset pod's strategies: * canary * rolling-update * unknow |
|
limits
Package limits contains function to calculate pod create/deletion limits.
|
Package limits contains function to calculate pod create/deletion limits. |