controllers

Documentation

Index

• Constants
• Variables
• func IsSNRMatching(ctx context.Context, c client.Client, snr *v1alpha1.SelfNodeRemediation, ...) (bool, string, error)
• type SelfNodeRemediationConfigReconciler
  • func (r *SelfNodeRemediationConfigReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *SelfNodeRemediationConfigReconciler) SetupWithManager(mgr ctrl.Manager) error
• type SelfNodeRemediationReconciler
  • func (r *SelfNodeRemediationReconciler) Reconcile(ctx context.Context, req ctrl.Request) (returnResult ctrl.Result, returnErr error)
  • func (r *SelfNodeRemediationReconciler) ReconcileAgent(ctx context.Context, req ctrl.Request) (returnResult ctrl.Result, returnErr error)
  • func (r *SelfNodeRemediationReconciler) ReconcileManager(ctx context.Context, req ctrl.Request) (returnResult ctrl.Result, returnErr error)
  • func (r *SelfNodeRemediationReconciler) SetupWithManager(mgr ctrl.Manager) error
• type UnreconcilableError
  • func (e *UnreconcilableError) Error() string

Constants

const (
	SNRFinalizer = "self-node-remediation.medik8s.io/snr-finalizer"
)

Variables

var (
	NodeUnschedulableTaint = &v1.Taint{
		Key:    "node.kubernetes.io/unschedulable",
		Effect: v1.TaintEffectNoSchedule,
	}

	NodeNoExecuteTaint = &v1.Taint{
		Key:    "medik8s.io/remediation",
		Value:  "self-node-remediation",
		Effect: v1.TaintEffectNoExecute,
	}

	OutOfServiceTaint = &v1.Taint{
		Key:    "node.kubernetes.io/out-of-service",
		Value:  "nodeshutdown",
		Effect: v1.TaintEffectNoExecute,
	}
)

Functions

func IsSNRMatching

func IsSNRMatching(ctx context.Context, c client.Client, snr *v1alpha1.SelfNodeRemediation, nodeName string, machineName string, log logr.Logger) (bool, string, error)

IsSNRMatching checks if the SNR CR is matching the node or machine name, and additionally returns the node name for the SNR in case machineName is empty

Types

type SelfNodeRemediationConfigReconciler

type SelfNodeRemediationConfigReconciler struct {
	client.Client
	Log                      logr.Logger
	Scheme                   *runtime.Scheme
	InstallFileFolder        string
	Namespace                string
	RebootDurationCalculator reboot.Calculator
}

SelfNodeRemediationConfigReconciler reconciles a SelfNodeRemediationConfig object

func (*SelfNodeRemediationConfigReconciler) Reconcile

func (r *SelfNodeRemediationConfigReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

func (*SelfNodeRemediationConfigReconciler) SetupWithManager

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

SetupWithManager sets up the controller with the Manager.

type SelfNodeRemediationReconciler

type SelfNodeRemediationReconciler struct {
	client.Client
	Log logr.Logger

	Scheme                   *runtime.Scheme
	Recorder                 record.EventRecorder
	Rebooter                 reboot.Rebooter
	RebootDurationCalculator reboot.Calculator
	MyNodeName               string
	MyNamespace              string
	IsAgent                  bool
	// contains filtered or unexported fields
}

SelfNodeRemediationReconciler reconciles a SelfNodeRemediation object

func (*SelfNodeRemediationReconciler) Reconcile

func (r *SelfNodeRemediationReconciler) Reconcile(ctx context.Context, req ctrl.Request) (returnResult ctrl.Result, returnErr error)

func (*SelfNodeRemediationReconciler) ReconcileAgent

func (r *SelfNodeRemediationReconciler) ReconcileAgent(ctx context.Context, req ctrl.Request) (returnResult ctrl.Result, returnErr error)

func (*SelfNodeRemediationReconciler) ReconcileManager

func (r *SelfNodeRemediationReconciler) ReconcileManager(ctx context.Context, req ctrl.Request) (returnResult ctrl.Result, returnErr error)

func (*SelfNodeRemediationReconciler) SetupWithManager

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

SetupWithManager sets up the controller with the Manager.

type UnreconcilableError

type UnreconcilableError struct {
	// contains filtered or unexported fields
}

func (*UnreconcilableError) Error

func (e *UnreconcilableError) Error() string