controllers

Documentation

Index

• func ApplyProfiles(params reconcileParameters, data *state.Data) error
• func EnsureLabelMap(params reconcileParameters, data *state.Data) error
• func HandleNode(params reconcileParameters, data *state.Data) error
• func MaintainProfileStates(params reconcileParameters, data *state.Data) error
• func UpdateMaintenanceStateLabel(params reconcileParameters, data *state.Data) error
• type Config
  • func LoadConfig(config *ucfgwrap.Config) (*Config, error)
• type ConfigDescriptor
• type NodeHandler
• type NodeReconciler
  • func (r *NodeReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *NodeReconciler) SetupWithManager(mgr ctrl.Manager) error
• type ProfileDescriptor
• type StateDescriptor
• type TransitionDescriptor

Functions

func ApplyProfiles

func ApplyProfiles(params reconcileParameters, data *state.Data) error

ensure a profile is assigned and profile states have been maintained beforehand.

func EnsureLabelMap

func EnsureLabelMap(params reconcileParameters, data *state.Data) error

func HandleNode

func HandleNode(params reconcileParameters, data *state.Data) error

func MaintainProfileStates

func MaintainProfileStates(params reconcileParameters, data *state.Data) error

ensure a profile is assigned beforehand.

func UpdateMaintenanceStateLabel

func UpdateMaintenanceStateLabel(params reconcileParameters, data *state.Data) error

Types

type Config

type Config struct {
	// RequeueInterval defines a duration after the a node is reconceiled again by the controller
	RequeueInterval time.Duration
	// Profiles contains all known profiles
	Profiles map[string]state.Profile
	// Contains reference to all plugins and their instances
	Registry plugin.Registry
}

Config represents the controllers global configuration.

func LoadConfig

func LoadConfig(config *ucfgwrap.Config) (*Config, error)

LoadConfig (re-)initializes the config with values provided by the given ucfg.Config.

type ConfigDescriptor

type ConfigDescriptor struct {
	Intervals struct {
		Requeue time.Duration `config:"requeue" validate:"required"`
	} `config:"intervals" validate:"required"`
	Instances plugin.InstancesDescriptor
	Profiles  []ProfileDescriptor
}

ConfigDescriptor describes the configuration structure to be parsed.

type NodeHandler

type NodeHandler = func(params reconcileParameters, data *state.Data) error

type NodeReconciler

type NodeReconciler struct {
	client.Client
	Log           logr.Logger
	Scheme        *runtime.Scheme
	Recorder      record.EventRecorder
	NodeInfoCache cache.NodeInfoCache
}

NodeReconciler reconciles a Node object.

func (*NodeReconciler) Reconcile

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

Reconcile reconciles the given request.

func (*NodeReconciler) SetupWithManager

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

SetupWithManager attaches the controller to the given manager.

type ProfileDescriptor

type ProfileDescriptor struct {
	Name                string `config:"name" validate:"required"`
	Operational         StateDescriptor
	MaintenanceRequired StateDescriptor `config:"maintenance-required"`
	InMaintenance       StateDescriptor `config:"in-maintenance"`
}

type StateDescriptor

type StateDescriptor struct {
	Notify      string
	Transitions []TransitionDescriptor
}

type TransitionDescriptor

type TransitionDescriptor struct {
	Check   string `config:"check" validate:"required"`
	Next    string `config:"next" validate:"required"`
	Trigger string
}