controllers

Documentation

Index

• Variables
• type CK8sConfigReconciler
  • func (r *CK8sConfigReconciler) Reconcile(ctx context.Context, req ctrl.Request) (_ reconcile.Result, rerr error)
  • func (r *CK8sConfigReconciler) SetupWithManager(mgr ctrl.Manager) error
• type CertificatesReconciler
  • func (r *CertificatesReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *CertificatesReconciler) SetupWithManager(mgr ctrl.Manager) error
• type CertificatesScope
• type InPlaceUpgradeReconciler
  • func (r *InPlaceUpgradeReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *InPlaceUpgradeReconciler) SetupWithManager(mgr ctrl.Manager) error
• type InitLocker
• type MachineDeploymentReconciler
  • func (r *MachineDeploymentReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *MachineDeploymentReconciler) SetupWithManager(mgr ctrl.Manager) error
• type MachineDeploymentUpgradeScope
• type MachineGetter
• type Scope
• type UpgradeScope

Variables

var (
	ErrInvalidRef   = errors.New("invalid reference")
	ErrFailedUnlock = errors.New("failed to unlock the init lock")
)

Types

type CK8sConfigReconciler

type CK8sConfigReconciler struct {
	client.Client
	Log          logr.Logger
	CK8sInitLock InitLocker
	Scheme       *runtime.Scheme

	K8sdDialTimeout time.Duration
	// contains filtered or unexported fields
}

CK8sConfigReconciler reconciles a CK8sConfig object.

func (*CK8sConfigReconciler) Reconcile

func (r *CK8sConfigReconciler) Reconcile(ctx context.Context, req ctrl.Request) (_ reconcile.Result, rerr error)

func (*CK8sConfigReconciler) SetupWithManager

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

type CertificatesReconciler

type CertificatesReconciler struct {
	client.Client
	Log    logr.Logger
	Scheme *runtime.Scheme

	K8sdDialTimeout time.Duration
	// contains filtered or unexported fields
}

CertificatesReconciler reconciles a Machine's certificates.

func (*CertificatesReconciler) Reconcile

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

func (*CertificatesReconciler) SetupWithManager

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

SetupWithManager sets up the controller with the Manager.

type CertificatesScope

type CertificatesScope struct {
	Cluster  *clusterv1.Cluster
	Config   *bootstrapv1.CK8sConfig
	Log      logr.Logger
	Machine  *clusterv1.Machine
	Patcher  *patch.Helper
	Workload *ck8s.Workload
}

type InPlaceUpgradeReconciler

type InPlaceUpgradeReconciler struct {
	client.Client
	Log    logr.Logger
	Scheme *runtime.Scheme

	K8sdDialTimeout time.Duration
	// contains filtered or unexported fields
}

InPlaceUpgradeReconciler reconciles machines and performs in-place upgrades based on annotations.

func (*InPlaceUpgradeReconciler) Reconcile

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

func (*InPlaceUpgradeReconciler) SetupWithManager

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

type InitLocker

type InitLocker interface {
	Lock(ctx context.Context, cluster *clusterv1.Cluster, machine *clusterv1.Machine) bool
	Unlock(ctx context.Context, cluster *clusterv1.Cluster) bool
}

InitLocker is a lock that is used around control plane init.

type MachineDeploymentReconciler

type MachineDeploymentReconciler struct {
	client.Client
	Log logr.Logger
	// contains filtered or unexported fields
}

MachineDeploymentReconciler reconciles a MachineDeployment object and manages the in-place upgrades.

func (*MachineDeploymentReconciler) Reconcile

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

Reconcile handles the reconciliation of a MachineDeployment object.

func (*MachineDeploymentReconciler) SetupWithManager

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

NewMachineDeploymentReconciler creates a new MachineDeploymentReconciler.

type MachineDeploymentUpgradeScope

type MachineDeploymentUpgradeScope struct {
	MachineDeployment *clusterv1.MachineDeployment
	PatchHelper       *patch.Helper
	UpgradeTo         string
	OwnedMachines     []*clusterv1.Machine
}

MachineDeploymentUpgradeScope is a struct that holds the context of the upgrade process.

type MachineGetter

type MachineGetter interface {
	GetMachinesForCluster(ctx context.Context, cluster client.ObjectKey, filters ...collections.Func) (collections.Machines, error)
}

MachineGetter is an interface that defines the methods a MachineDeploymentReconciler uses to get machines.

type Scope

type Scope struct {
	logr.Logger
	Config      *bootstrapv1.CK8sConfig
	ConfigOwner *bsutil.ConfigOwner
	Cluster     *clusterv1.Cluster
}

type UpgradeScope

type UpgradeScope struct {
	Log             logr.Logger
	Cluster         *clusterv1.Cluster
	WorkloadCluster *ck8s.Workload
	Machine         *clusterv1.Machine
	PatchHelper     *patch.Helper
	UpgradeOption   string
}