nodedaemon

Documentation

Index

• Constants
• func CreateOrUpdateDaemonset(ctx context.Context, c client.Client, ...) (*appsv1.DaemonSet, controllerutil.OperationResult, error)
• func MutateAggregatedSpec(ds *appsv1.DaemonSet, tolerations []corev1.Toleration, ...)
• type DaemonReconciler
  • func (r *DaemonReconciler) Reconcile(ctx context.Context, request ctrl.Request) (ctrl.Result, error)
  • func (r *DaemonReconciler) SetupWithManager(mgr ctrl.Manager) error

Constants

const (

	// ProvisionerName is the name of the local-static-provisioner daemonset
	ProvisionerName = "local-provisioner"
	// DiskMakerName is the name of the diskmaker-manager daemonset
	DiskMakerName = "diskmaker-manager"
)

Functions

func CreateOrUpdateDaemonset

func CreateOrUpdateDaemonset(
	ctx context.Context,
	c client.Client,
	daemonSetMutateFn func(*appsv1.DaemonSet) error,
) (*appsv1.DaemonSet, controllerutil.OperationResult, error)

createOrUpdateDaemonset fetches and creates/updates ds according to desiredDs fields that are not allowed update at runtime are not copied unless the creationtimestamp is zero

func MutateAggregatedSpec

func MutateAggregatedSpec(
	ds *appsv1.DaemonSet,
	tolerations []corev1.Toleration,
	ownerRefs []metav1.OwnerReference,
	nodeSelector *corev1.NodeSelector,
	dsTemplate *appsv1.DaemonSet,
)

MutateAggregatedSpec returns a mutate function that applies the other arguments to the referenced daemonset its purpose is to be used in more specific mutate functions that can that be applied to an empty corev1.DaemonSet{} before a Create() or applied to an existing one before an Update()

Types

type DaemonReconciler

type DaemonReconciler struct {
	// This client, initialized using mgr.Client() above, is a split client
	// that reads objects from the cache and writes to the apiserver
	Client client.Client
	Scheme *runtime.Scheme
	// contains filtered or unexported fields
}

DaemonReconciler reconciles all LocalVolumeSet objects at once

func (*DaemonReconciler) Reconcile

func (r *DaemonReconciler) Reconcile(ctx context.Context, request ctrl.Request) (ctrl.Result, error)

Reconcile reads that state of the cluster for a LocalVolumeSet object and makes changes based on the state read and what is in the LocalVolumeSet.Spec 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.

func (*DaemonReconciler) SetupWithManager

func (r *DaemonReconciler) SetupWithManager(mgr ctrl.Manager) error

SetupWithManager sets up the controller with the Manager.