controller

Documentation

Index

• Constants
• func FindNodeStatusCondition(conditions []corev1.NodeCondition, conditionType corev1.NodeConditionType) *corev1.NodeCondition
• func HasStatusCondition(conditions []metav1.Condition, conditionType string) bool
• func InstanceHaUrl(region, zone, hostname string) string
• func IsNodeConditionPresentAndEqual(conditions []corev1.NodeCondition, conditionType corev1.NodeConditionType, ...) bool
• func IsNodeConditionTrue(conditions []corev1.NodeCondition, conditionType corev1.NodeConditionType) bool
• type AggregatesController
  • func (r *AggregatesController) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *AggregatesController) SetupWithManager(mgr ctrl.Manager) error
• type EvictionReconciler
  • func (r *EvictionReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *EvictionReconciler) SetupWithManager(mgr ctrl.Manager) error
• type HypervisorController
  • func (hv *HypervisorController) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (hv *HypervisorController) SetupWithManager(mgr ctrl.Manager) error
• type MaintenanceController
  • func (r *MaintenanceController) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *MaintenanceController) SetupWithManager(mgr ctrl.Manager, namespace string) error
• type NodeCertificateController
  • func (r *NodeCertificateController) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *NodeCertificateController) SetupWithManager(mgr ctrl.Manager, namespace, issuerName string) error
• type NodeDecommissionReconciler
  • func (r *NodeDecommissionReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *NodeDecommissionReconciler) SetupWithManager(mgr ctrl.Manager) error
• type NodeEvictionLabelReconciler
  • func (r *NodeEvictionLabelReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *NodeEvictionLabelReconciler) SetupWithManager(mgr ctrl.Manager) error
• type OnboardingController
  • func (r *OnboardingController) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *OnboardingController) SetupWithManager(mgr ctrl.Manager) error
• type TraitsController
  • func (r *TraitsController) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *TraitsController) SetupWithManager(mgr ctrl.Manager) error

Constants

const (
	ConditionTypeOnboarding   = "Onboarding"
	ConditionReasonInitial    = "initial"
	ConditionReasonOnboarding = "onboarding"
	ConditionReasonTesting    = "testing"
	ConditionReasonCompleted  = "completed"
	ConditionReasonReady      = "ready"
)

Functions

func FindNodeStatusCondition

func FindNodeStatusCondition(conditions []corev1.NodeCondition, conditionType corev1.NodeConditionType) *corev1.NodeCondition

FindNodeStatusCondition returns the condition of the given type if it exists.

func HasStatusCondition

func HasStatusCondition(conditions []metav1.Condition, conditionType string) bool

func InstanceHaUrl

func InstanceHaUrl(region, zone, hostname string) string

func IsNodeConditionPresentAndEqual

func IsNodeConditionPresentAndEqual(conditions []corev1.NodeCondition, conditionType corev1.NodeConditionType, status corev1.ConditionStatus) bool

IsNodeConditionPresentAndEqual returns true when conditionType is present and equal to status.

func IsNodeConditionTrue

func IsNodeConditionTrue(conditions []corev1.NodeCondition, conditionType corev1.NodeConditionType) bool

IsNodeConditionTrue returns true when the conditionType is present and set to `corev1.ConditionTrue`

Types

type AggregatesController

type AggregatesController struct {
	k8sclient.Client
	Scheme *runtime.Scheme
	// contains filtered or unexported fields
}

func (*AggregatesController) Reconcile

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

+kubebuilder:rbac:groups="",resources=nodes,verbs=get;list;watch;patch

func (*AggregatesController) SetupWithManager

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

SetupWithManager sets up the controller with the Manager.

type EvictionReconciler

type EvictionReconciler struct {
	client.Client
	Scheme *runtime.Scheme
	// contains filtered or unexported fields
}

EvictionReconciler reconciles a Eviction object

func (*EvictionReconciler) Reconcile

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

Reconcile is part of the main kubernetes reconciliation loop which aims to move the current state of the cluster closer to the desired state.

func (*EvictionReconciler) SetupWithManager

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

SetupWithManager sets up the controller with the Manager.

type HypervisorController

type HypervisorController struct {
	k8sclient.Client
	Scheme *runtime.Scheme
}

func (*HypervisorController) Reconcile

func (hv *HypervisorController) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

func (*HypervisorController) SetupWithManager

func (hv *HypervisorController) SetupWithManager(mgr ctrl.Manager) error

type MaintenanceController

type MaintenanceController struct {
	k8sclient.Client
	Scheme *runtime.Scheme
	// contains filtered or unexported fields
}

func (*MaintenanceController) Reconcile

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

func (*MaintenanceController) SetupWithManager

func (r *MaintenanceController) SetupWithManager(mgr ctrl.Manager, namespace string) error

SetupWithManager sets up the controller with the Manager.

type NodeCertificateController

type NodeCertificateController struct {
	k8sclient.Client
	Scheme *runtime.Scheme
	// contains filtered or unexported fields
}

func (*NodeCertificateController) Reconcile

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

Reconcile is part of the main kubernetes reconciliation loop which aims to move the current state of the cluster closer to the desired state.

func (*NodeCertificateController) SetupWithManager

func (r *NodeCertificateController) SetupWithManager(mgr ctrl.Manager, namespace, issuerName string) error

SetupWithManager sets up the controller with the Manager.

type NodeDecommissionReconciler

type NodeDecommissionReconciler struct {
	k8sclient.Client
	Scheme *runtime.Scheme
	// contains filtered or unexported fields
}

func (*NodeDecommissionReconciler) Reconcile

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

+kubebuilder:rbac:groups="",resources=nodes,verbs=get;list;watch;patch;update +kubebuilder:rbac:groups="",resources=nodes/finalizers,verbs=update

func (*NodeDecommissionReconciler) SetupWithManager

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

SetupWithManager sets up the controller with the Manager.

type NodeEvictionLabelReconciler

type NodeEvictionLabelReconciler struct {
	k8sclient.Client
	Scheme *runtime.Scheme
}

func (*NodeEvictionLabelReconciler) Reconcile

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

func (*NodeEvictionLabelReconciler) SetupWithManager

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

SetupWithManager sets up the controller with the Manager.

type OnboardingController

type OnboardingController struct {
	k8sclient.Client
	Scheme *runtime.Scheme
	// contains filtered or unexported fields
}

func (*OnboardingController) Reconcile

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

+kubebuilder:rbac:groups=kvm.cloud.sap,resources=hypervisors,verbs=get;list;watch;patch

func (*OnboardingController) SetupWithManager

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

SetupWithManager sets up the controller with the Manager.

type TraitsController

type TraitsController struct {
	k8sclient.Client
	Scheme *runtime.Scheme
	// contains filtered or unexported fields
}

func (*TraitsController) Reconcile

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

func (*TraitsController) SetupWithManager

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

SetupWithManager sets up the controller with the Manager.