loadbalancerset

Documentation

Index

• Constants
• type LBMStatusReconciler
  • func (r *LBMStatusReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *LBMStatusReconciler) SetupWithManager(mgr ctrl.Manager) error
• type LoadBalancerSetReconciler
  • func (r *LoadBalancerSetReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *LoadBalancerSetReconciler) SetupWithManager(mgr ctrl.Manager) error

Constants

const FINALIZER = "stackit.cloud/loadbalancermachine"

Types

type LBMStatusReconciler

type LBMStatusReconciler struct {
	client.Client
	WorkerCount int
	RateLimiter workqueue.TypedRateLimiter[reconcile.Request]

	DeletionGracePeriod time.Duration
}

LBMStatusReconciler watches LoadBalancerMachines and determines if a machine should be deleted. A machine should be deleted if its conditions are either stale, or have been in a not-healthy state for some time.

Deletion is not performed immediately, instead a new Condition is added, and after `DeletionGracePeriod` has passed (and the machine is still not ready), the object is actually deleted. This ensures that after an e.g. API Server (where both yawollet and the yawol-controllers cannot update the status), the yawollet is given a chance to update the heartbeat.

func (*LBMStatusReconciler) Reconcile

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

func (*LBMStatusReconciler) SetupWithManager

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

type LoadBalancerSetReconciler

type LoadBalancerSetReconciler struct {
	client.Client
	Log         logr.Logger
	Scheme      *runtime.Scheme
	Recorder    record.EventRecorder
	Metrics     *helpermetrics.LoadBalancerSetMetricList
	WorkerCount int
	RateLimiter workqueue.TypedRateLimiter[reconcile.Request]
}

LoadBalancerSetReconciler reconciles service Objects with type LoadBalancer

func (*LoadBalancerSetReconciler) Reconcile

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

+kubebuilder:rbac:groups=core,resources=services,verbs=get;list;watch

func (*LoadBalancerSetReconciler) SetupWithManager

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