extendeddaemonsetreplicaset

Documentation

Index

• func FilterAndMapPodsByNode(logger logr.Logger, replicaset *datadoghqv1alpha1.ExtendedDaemonSetReplicaSet, ...) (nodesByName map[string]*strategy.NodeItem, ...)
• 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) Reconcile(ctx context.Context, request reconcile.Request) (reconcile.Result, error)
• type ReconcilerOptions

Functions

func FilterAndMapPodsByNode

func FilterAndMapPodsByNode(logger logr.Logger, replicaset *datadoghqv1alpha1.ExtendedDaemonSetReplicaSet,
	nodeList *strategy.NodeList, podList *corev1.PodList, ignoreNodes []string) (nodesByName map[string]*strategy.NodeItem, podByNode map[*strategy.NodeItem]*corev1.Pod,
	podToDelete, unscheduledPods []*corev1.Pod)

FilterAndMapPodsByNode used to map pods by associated node. It also return the list of pods that should be deleted (not needed anymore), and pods that are not scheduled yet (created but not scheduled)

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) 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