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 NodeImageReconciler
  • func NewNodeImageReconciler(nodeReplacer nodeReplacer, etcdRemover etcdRemover, client client.Client, ...) *NodeImageReconciler
  • func (r *NodeImageReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *NodeImageReconciler) 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 NodeImageReconciler

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

NodeImageReconciler reconciles a NodeImage object.

func NewNodeImageReconciler

func NewNodeImageReconciler(nodeReplacer nodeReplacer, etcdRemover etcdRemover, client client.Client, scheme *runtime.Scheme) *NodeImageReconciler

NewNodeImageReconciler creates a new NodeImageReconciler.

func (*NodeImageReconciler) Reconcile

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

Reconcile replaces outdated nodes (using an old image) with new nodes (using a new image) as specified in the NodeImage spec.

func (*NodeImageReconciler) SetupWithManager

func (r *NodeImageReconciler) 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 NodeImage 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.