controllers

Documentation

Index

• Constants
• Variables
• func TrackConditionType(conditions *[]metav1.Condition, ...)
• type ExternalClusterReferenceReconciler
  • func (r *ExternalClusterReferenceReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *ExternalClusterReferenceReconciler) SetupWithManager(mgr ctrl.Manager) error
• type KamajiControlPlaneReconciler
  • func (r *KamajiControlPlaneReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *KamajiControlPlaneReconciler) SetupWithManager(mgr ctrl.Manager, channel chan event.GenericEvent) error
• type PushKamajiChange
  • func (p *PushKamajiChange) Reconcile(ctx context.Context, request reconcile.Request) (reconcile.Result, error)
  • func (p *PushKamajiChange) SetupWithManager(mgr ctrl.Manager) error
• type UnmanagedControlPlaneAddressError
  • func NewUnmanagedControlPlaneAddressError(kind string) *UnmanagedControlPlaneAddressError
  • func (u UnmanagedControlPlaneAddressError) Error() string

Constants

const (
	ExternalClusterReferenceFinalizer = "ecr.kamaji.clastix.io/finalizer"
)

Variables

var (
	ErrExternalClusterReferenceNotEnabled                 = errors.New("external cluster feature gates are not enabled")
	ErrExternalClusterReferenceCrossNamespaceReference    = errors.New("the ExternalClusterReference is enforcing kubeconfig in the same Namespace, ExternalClusterReferenceCrossNamespace must be enabled")
	ErrExternalCLusterReferenceSecretEmptyError           = errors.New("could not extract kubeconfig for external cluster reference, secret is empty")
	ErrExternalClusterReferenceSecretKeyEmpty             = errors.New("could not extract kubeconfig for external cluster reference, key is empty")
	ErrExternalClusterReferenceNonInitializedStore        = errors.New("remote manager is not yet initialized")
	ErrExternalClusterReferenceTenantControlPlaneNotFound = errors.New("TenantControlPlane custom resource not available in external cluster")
)

var ErrEnqueueBack = errors.New("enqueue back")

Functions

func TrackConditionType

func TrackConditionType(conditions *[]metav1.Condition, conditionType v1alpha1.KamajiControlPlaneConditionType, observedGeneration int64, fn func() error)

Types

type ExternalClusterReferenceReconciler

type ExternalClusterReferenceReconciler struct {
	Client         client.Client
	Store          externalclusterreference.Store
	TriggerChannel chan event.GenericEvent
}

func (*ExternalClusterReferenceReconciler) Reconcile

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

func (*ExternalClusterReferenceReconciler) SetupWithManager

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

type KamajiControlPlaneReconciler

type KamajiControlPlaneReconciler struct {
	ExternalClusterReferenceStore externalclusterreference.Store
	FeatureGates                  featuregate.FeatureGate
	MaxConcurrentReconciles       int
	// contains filtered or unexported fields
}

KamajiControlPlaneReconciler reconciles a KamajiControlPlane object.

func (*KamajiControlPlaneReconciler) Reconcile

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

func (*KamajiControlPlaneReconciler) SetupWithManager

func (r *KamajiControlPlaneReconciler) SetupWithManager(mgr ctrl.Manager, channel chan event.GenericEvent) error

SetupWithManager sets up the controller with the Manager.

type PushKamajiChange

type PushKamajiChange struct {
	ParentClient   client.Client
	Client         client.Client
	TriggerChannel chan event.GenericEvent
}

func (*PushKamajiChange) Reconcile

func (p *PushKamajiChange) Reconcile(ctx context.Context, request reconcile.Request) (reconcile.Result, error)

func (*PushKamajiChange) SetupWithManager

func (p *PushKamajiChange) SetupWithManager(mgr ctrl.Manager) error

type UnmanagedControlPlaneAddressError

type UnmanagedControlPlaneAddressError struct {
	Kind string
}

func NewUnmanagedControlPlaneAddressError

func NewUnmanagedControlPlaneAddressError(kind string) *UnmanagedControlPlaneAddressError

func (UnmanagedControlPlaneAddressError) Error

func (u UnmanagedControlPlaneAddressError) Error() string