extendeddaemonsetreplicaset

Documentation

Overview

Package extendeddaemonsetreplicaset contains ExtendedDaemonsetReplicaset controller logic.

Index

• func FilterPodsByNode(podsByNodeName map[string][]*corev1.Pod, ...) (map[*strategy.NodeItem]*corev1.Pod, []*corev1.Pod)
• type Reconciler
  • func NewReconciler(options ReconcilerOptions, client client.Client, scheme *runtime.Scheme, ...) (*Reconciler, error)
  • func (r *Reconciler) FilterAndMapPodsByNode(logger logr.Logger, replicaset *datadoghqv1alpha1.ExtendedDaemonSetReplicaSet, ...) (nodesByName map[string]*strategy.NodeItem, ...)
  • func (r *Reconciler) Reconcile(ctx context.Context, request reconcile.Request) (reconcile.Result, error)
• type ReconcilerOptions

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

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.