controller

package
v0.0.0-...-094d74d Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jan 30, 2026 License: Apache-2.0 Imports: 41 Imported by: 0

Documentation

Index

Constants

View Source
const ManagedControlPlaneFinalizer = "controlplane.patrostkowski.dev/finalizer" // ManagedControlPlaneFinalizer is the finalizer used for ManagedControlPlane objects.
View Source
const RequeueAfterFailure = 10 * time.Second // RequeueAfterFailure specifies the duration to wait before requeueing a failed reconciliation.

Variables

This section is empty.

Functions

func SetupManagedAddonController

func SetupManagedAddonController(mgr ctrl.Manager) error

SetupManagedAddonController sets up the ManagedAddon controller with the Kubernetes manager.

func SetupManagedControlPlaneController

func SetupManagedControlPlaneController(mgr ctrl.Manager) error

SetupManagedControlPlaneController sets up the ManagedControlPlane controller with the Kubernetes manager.

Types

type APIServerComponent

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

APIServerComponent reconciles the Kubernetes API server deployment.

func (*APIServerComponent) FailedMessage

func (c *APIServerComponent) FailedMessage() mcpv1alpha1.Message

FailedMessage returns the failed message for the API server.

func (*APIServerComponent) Name

func (c *APIServerComponent) Name() string

Name returns the name of the API server component.

func (*APIServerComponent) Reconcile

Reconcile reconciles the API server deployment.

func (*APIServerComponent) WaitingMessage

func (c *APIServerComponent) WaitingMessage() mcpv1alpha1.Message

WaitingMessage returns the waiting message for the API server.

type APIServerServiceComponent

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

APIServerServiceComponent reconciles the Kubernetes API server service.

func (*APIServerServiceComponent) FailedMessage

func (c *APIServerServiceComponent) FailedMessage() mcpv1alpha1.Message

FailedMessage returns the failed message for the API server service.

func (*APIServerServiceComponent) Name

Name returns the name of the API server service component.

func (*APIServerServiceComponent) Reconcile

Reconcile reconciles the API server service.

func (*APIServerServiceComponent) WaitingMessage

func (c *APIServerServiceComponent) WaitingMessage() mcpv1alpha1.Message

WaitingMessage returns the waiting message for the API server service.

type AdminConfigComponent

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

AdminConfigComponent reconciles the admin kubeconfig secret for the control plane.

func (*AdminConfigComponent) FailedMessage

func (c *AdminConfigComponent) FailedMessage() mcpv1alpha1.Message

FailedMessage returns the failed message for the admin kubeconfig.

func (*AdminConfigComponent) Name

func (c *AdminConfigComponent) Name() string

Name returns the name of the admin kubeconfig component.

func (*AdminConfigComponent) Reconcile

Reconcile reconciles the admin kubeconfig secret.

func (*AdminConfigComponent) WaitingMessage

func (c *AdminConfigComponent) WaitingMessage() mcpv1alpha1.Message

WaitingMessage returns the waiting message for the admin kubeconfig.

type ApplyOptions

type ApplyOptions struct {
	FieldOwner  string
	Force       bool
	Owner       client.Object
	SetOwnerRef bool
	Log         logr.Logger
}

ApplyOptions defines options for server-side apply operations.

type BaseReconciler

type BaseReconciler struct {
	Log      logr.Logger
	Recorder record.EventRecorder
	Scheme   *runtime.Scheme
}

BaseReconciler provides common reconciliation utilities and fields.

type Component

type Component interface {
	Name() string
	Reconcile(ctx context.Context, cc *cluster.ClusterContext) (ctrl.Result, error)
	WaitingMessage() v1alpha1.Message
	FailedMessage() v1alpha1.Message
}

Component defines an interface for a reconcilable component within the control plane.

type ControlPlaneClient

type ControlPlaneClient struct {
	client.Client
	Discovery discovery.DiscoveryInterface
	REST      *rest.Config
}

ControlPlaneClient bundles client interfaces for interacting with the managed control plane.

func New

New creates a new ControlPlaneClient instance.

type ControllerManagerComponent

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

ControllerManagerComponent reconciles the Kubernetes Controller Manager.

func (*ControllerManagerComponent) FailedMessage

func (c *ControllerManagerComponent) FailedMessage() mcpv1alpha1.Message

FailedMessage returns the failed message for the controller manager.

func (*ControllerManagerComponent) Name

Name returns the name of the controller manager component.

func (*ControllerManagerComponent) Reconcile

Reconcile reconciles the controller manager deployment.

func (*ControllerManagerComponent) WaitingMessage

func (c *ControllerManagerComponent) WaitingMessage() mcpv1alpha1.Message

WaitingMessage returns the waiting message for the controller manager.

type ETCDComponent

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

ETCDComponent reconciles the etcd cluster.

func (*ETCDComponent) FailedMessage

func (c *ETCDComponent) FailedMessage() mcpv1alpha1.Message

FailedMessage returns the failed message for the etcd component.

func (*ETCDComponent) Name

func (c *ETCDComponent) Name() string

Name returns the name of the etcd component.

func (*ETCDComponent) Reconcile

func (c *ETCDComponent) Reconcile(ctx context.Context, cc *cluster.ClusterContext) (ctrl.Result, error)

Reconcile reconciles the etcd cluster.

func (*ETCDComponent) WaitingMessage

func (c *ETCDComponent) WaitingMessage() mcpv1alpha1.Message

WaitingMessage returns the waiting message for the etcd component.

type ManagedAddonsReconciler

type ManagedAddonsReconciler struct {
	BaseReconciler
	client.Client
	// contains filtered or unexported fields
}

ManagedAddonsReconciler reconciles ManagedAddons objects.

func (*ManagedAddonsReconciler) Reconcile

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

Reconcile performs the main reconciliation loop for managed addons.

type ManagedControlPlaneReconciler

type ManagedControlPlaneReconciler struct {
	BaseReconciler
	client.Client
}

ManagedControlPlaneReconciler reconciles ManagedControlPlane objects.

func (*ManagedControlPlaneReconciler) Reconcile

Reconcile performs the main reconciliation loop for ManagedControlPlane objects.

type PKIComponent

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

PKIComponent reconciles the Public Key Infrastructure (PKI) resources.

func (*PKIComponent) FailedMessage

func (c *PKIComponent) FailedMessage() mcpv1alpha1.Message

FailedMessage returns the failed message for the PKI component.

func (*PKIComponent) Name

func (c *PKIComponent) Name() string

Name returns the name of the PKI component.

func (*PKIComponent) Reconcile

func (c *PKIComponent) Reconcile(ctx context.Context, cc *cluster.ClusterContext) (ctrl.Result, error)

Reconcile reconciles the PKI resources.

func (*PKIComponent) WaitingMessage

func (c *PKIComponent) WaitingMessage() mcpv1alpha1.Message

WaitingMessage returns the waiting message for the PKI component.

type SchedulerComponent

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

SchedulerComponent reconciles the Kubernetes scheduler.

func (*SchedulerComponent) FailedMessage

func (c *SchedulerComponent) FailedMessage() mcpv1alpha1.Message

FailedMessage returns the failed message for the scheduler component.

func (*SchedulerComponent) Name

func (c *SchedulerComponent) Name() string

Name returns the name of the scheduler component.

func (*SchedulerComponent) Reconcile

Reconcile reconciles the scheduler deployment.

func (*SchedulerComponent) WaitingMessage

func (c *SchedulerComponent) WaitingMessage() mcpv1alpha1.Message

WaitingMessage returns the waiting message for the scheduler component.

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL