controllers

Documentation

Index

• type AutoscalingStrategyReconciler
  • func (r *AutoscalingStrategyReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *AutoscalingStrategyReconciler) SetupWithManager(mgr ctrl.Manager) error
• type JoiningNodesReconciler
  • func NewJoiningNodesReconciler(client client.Client, scheme *runtime.Scheme) *JoiningNodesReconciler
  • func (r *JoiningNodesReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *JoiningNodesReconciler) SetupWithManager(mgr ctrl.Manager) error
• type NodeVersionReconciler
  • func NewNodeVersionReconciler(nodeReplacer nodeReplacer, etcdRemover etcdRemover, ...) *NodeVersionReconciler
  • func (r *NodeVersionReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *NodeVersionReconciler) SetupWithManager(mgr ctrl.Manager) error
• type PendingNodeReconciler
  • func NewPendingNodeReconciler(nodeStateGetter nodeStateGetter, client client.Client, scheme *runtime.Scheme) *PendingNodeReconciler
  • func (r *PendingNodeReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *PendingNodeReconciler) SetupWithManager(mgr ctrl.Manager) error
• type ScalingGroupReconciler
  • func NewScalingGroupReconciler(scalingGroupUpdater scalingGroupUpdater, client client.Client, ...) *ScalingGroupReconciler
  • func (r *ScalingGroupReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *ScalingGroupReconciler) SetupWithManager(mgr ctrl.Manager) error

Types

type AutoscalingStrategyReconciler

type AutoscalingStrategyReconciler struct {
	client.Client
	Scheme *runtime.Scheme
}

AutoscalingStrategyReconciler reconciles a AutoscalingStrategy object.

func (*AutoscalingStrategyReconciler) Reconcile

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

Reconcile enabled or disables the cluster-autoscaler based on the AutoscalingStrategy spec by modifying the replicas of the Deployment.

func (*AutoscalingStrategyReconciler) SetupWithManager

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

SetupWithManager sets up the controller with the Manager.

type JoiningNodesReconciler

type JoiningNodesReconciler struct {
	client.Client
	Scheme *runtime.Scheme
	clock.Clock
}

JoiningNodesReconciler reconciles a JoiningNode object.

func NewJoiningNodesReconciler

func NewJoiningNodesReconciler(client client.Client, scheme *runtime.Scheme) *JoiningNodesReconciler

NewJoiningNodesReconciler creates a new JoiningNodesReconciler.

func (*JoiningNodesReconciler) Reconcile

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

Reconcile annotates the node with the components hash.

func (*JoiningNodesReconciler) SetupWithManager

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

SetupWithManager sets up the controller with the Manager.

type NodeVersionReconciler

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

NodeVersionReconciler reconciles a NodeVersion object.

func NewNodeVersionReconciler

func NewNodeVersionReconciler(nodeReplacer nodeReplacer, etcdRemover etcdRemover, clusterUpgrader clusterUpgrader, k8sVerGetter kubernetesServerVersionGetter, client client.Client, scheme *runtime.Scheme) *NodeVersionReconciler

NewNodeVersionReconciler creates a new NodeVersionReconciler.

func (*NodeVersionReconciler) Reconcile

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

Reconcile replaces outdated nodes with new nodes as specified in the NodeVersion spec.

func (*NodeVersionReconciler) SetupWithManager

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

SetupWithManager sets up the controller with the Manager.

type PendingNodeReconciler

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

PendingNodeReconciler reconciles a PendingNode object.

func NewPendingNodeReconciler

func NewPendingNodeReconciler(nodeStateGetter nodeStateGetter, client client.Client, scheme *runtime.Scheme) *PendingNodeReconciler

NewPendingNodeReconciler creates a new PendingNodeReconciler.

func (*PendingNodeReconciler) Reconcile

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

Reconcile observes the state of a pending node that is either trying to join the cluster or is leaving the cluster (waiting to be destroyed). If the node is trying to join the cluster and fails to join within the deadline referenced in the PendingNode spec, the node is deleted.

func (*PendingNodeReconciler) SetupWithManager

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

SetupWithManager sets up the controller with the Manager.

type ScalingGroupReconciler

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

ScalingGroupReconciler reconciles a ScalingGroup object.

func NewScalingGroupReconciler

func NewScalingGroupReconciler(scalingGroupUpdater scalingGroupUpdater, client client.Client, scheme *runtime.Scheme) *ScalingGroupReconciler

NewScalingGroupReconciler returns a new ScalingGroupReconciler.

func (*ScalingGroupReconciler) Reconcile

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

Reconcile reads the latest node image from the referenced NodeVersion spec and updates the scaling group to match.

func (*ScalingGroupReconciler) SetupWithManager

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

SetupWithManager sets up the controller with the Manager.