sgreconciler

Documentation

Overview

Package sgreconciler contains a reconciler that reconciles on cloud provider infrastructure. It is used to create, delete and update the spec of infrastructure-related k8s resources based on the actual state of the infrastructure. It uses polling (with additional triggers) to check the state of the infrastructure.

Index

• type ExternalScalingGroupReconciler
  • func NewExternalScalingGroupReconciler(uid string, discoverer scalingGroupDiscoverer, k8sClient k8sReadWriter) *ExternalScalingGroupReconciler
  • func (r *ExternalScalingGroupReconciler) Reconcile(ctx context.Context) (executor.Result, error)
• type NodeJoinWatcher
  • func NewNodeJoinWatcher(trigger func(), client client.Client, scheme *runtime.Scheme) *NodeJoinWatcher
  • func (w *NodeJoinWatcher) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (w *NodeJoinWatcher) SetupWithManager(mgr ctrl.Manager) error

Types

type ExternalScalingGroupReconciler

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

ExternalScalingGroupReconciler reconciles on scaling groups in CSP infrastructure. It does NOT reconcile on k8s resources. Instead, it scans the cloud provider infrastructure and changes k8s resources accordingly.

func NewExternalScalingGroupReconciler

func NewExternalScalingGroupReconciler(uid string, discoverer scalingGroupDiscoverer, k8sClient k8sReadWriter) *ExternalScalingGroupReconciler

NewExternalScalingGroupReconciler creates a new InfrastructureReconciler.

func (*ExternalScalingGroupReconciler) Reconcile

func (r *ExternalScalingGroupReconciler) Reconcile(ctx context.Context) (executor.Result, error)

Reconcile reconciles on scaling groups in CSP infrastructure.

type NodeJoinWatcher

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

NodeJoinWatcher watches node join / leave events.

func NewNodeJoinWatcher

func NewNodeJoinWatcher(trigger func(), client client.Client, scheme *runtime.Scheme) *NodeJoinWatcher

NewNodeJoinWatcher creates a new NodeJoinWatcher.

func (*NodeJoinWatcher) Reconcile

func (w *NodeJoinWatcher) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

Reconcile reconciles node join / leave events.

func (*NodeJoinWatcher) SetupWithManager

func (w *NodeJoinWatcher) SetupWithManager(mgr ctrl.Manager) error

SetupWithManager sets up the controller with the Manager.