controllers

Documentation

Index

• func GetDeletableResources(tcp *kamajiv1alpha1.TenantControlPlane, ...) []resources.DeletableResource
• func GetExternalKonnectivityResources(c client.Client) []resources.Resource
• func GetResources(config GroupResourceBuilderConfiguration) []resources.Resource
• type CertificateChannel
• type CertificateLifecycle
  • func (s *CertificateLifecycle) Reconcile(ctx context.Context, request reconcile.Request) (reconcile.Result, error)
  • func (s *CertificateLifecycle) SetupWithManager(mgr controllerruntime.Manager) error
• type DataStore
  • func (r *DataStore) Reconcile(ctx context.Context, request reconcile.Request) (reconcile.Result, error)
  • func (r *DataStore) SetupWithManager(mgr controllerruntime.Manager) error
• type GroupDeletableResourceBuilderConfiguration
• type GroupResourceBuilderConfiguration
• type TelemetryController
  • func (m *TelemetryController) Start(ctx context.Context) error
• type TenantControlPlaneChannel
• type TenantControlPlaneReconciler
  • func (r *TenantControlPlaneReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *TenantControlPlaneReconciler) RemoveFinalizer(ctx context.Context, tenantControlPlane *kamajiv1alpha1.TenantControlPlane) error
  • func (r *TenantControlPlaneReconciler) SetupWithManager(mgr ctrl.Manager) error
• type TenantControlPlaneReconcilerConfig

Functions

func GetDeletableResources

func GetDeletableResources(tcp *kamajiv1alpha1.TenantControlPlane, config GroupDeletableResourceBuilderConfiguration) []resources.DeletableResource

GetDeletableResources returns a list of resources that have to be deleted when tenant control planes are deleted Currently there is only a default approach TODO: the idea of this function is to become a factory to return the group of deletable resources according to the given configuration.

func GetExternalKonnectivityResources

func GetExternalKonnectivityResources(c client.Client) []resources.Resource

func GetResources

func GetResources(config GroupResourceBuilderConfiguration) []resources.Resource

GetResources returns a list of resources that will be used to provide tenant control planes Currently there is only a default approach TODO: the idea of this function is to become a factory to return the group of resources according to the given configuration.

Types

type CertificateChannel

type CertificateChannel chan event.GenericEvent

type CertificateLifecycle

type CertificateLifecycle struct {
	Channel CertificateChannel
	// contains filtered or unexported fields
}

func (*CertificateLifecycle) Reconcile

func (s *CertificateLifecycle) Reconcile(ctx context.Context, request reconcile.Request) (reconcile.Result, error)

func (*CertificateLifecycle) SetupWithManager

func (s *CertificateLifecycle) SetupWithManager(mgr controllerruntime.Manager) error

type DataStore

type DataStore struct {
	Client client.Client
	// TenantControlPlaneTrigger is the channel used to communicate across the controllers:
	// if a Data Source is updated we have to be sure that the reconciliation of the certificates content
	// for each Tenant Control Plane is put in place properly.
	TenantControlPlaneTrigger TenantControlPlaneChannel
}

func (*DataStore) Reconcile

func (r *DataStore) Reconcile(ctx context.Context, request reconcile.Request) (reconcile.Result, error)

func (*DataStore) SetupWithManager

func (r *DataStore) SetupWithManager(mgr controllerruntime.Manager) error

type GroupDeletableResourceBuilderConfiguration

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

type GroupResourceBuilderConfiguration

type GroupResourceBuilderConfiguration struct {
	Connection           datastore.Connection
	DataStore            kamajiv1alpha1.DataStore
	KamajiNamespace      string
	KamajiServiceAccount string
	KamajiService        string
	KamajiMigrateImage   string
	// contains filtered or unexported fields
}

type TelemetryController

type TelemetryController struct {
	Client                  client.Client
	TelemetryClient         telemetry.Client
	LeaderElectionNamespace string
	LeaderElectionID        string
	KamajiVersion           string
	KubernetesVersion       string
}

func (*TelemetryController) Start

func (m *TelemetryController) Start(ctx context.Context) error

type TenantControlPlaneChannel

type TenantControlPlaneChannel chan event.GenericEvent

type TenantControlPlaneReconciler

type TenantControlPlaneReconciler struct {
	Client                  client.Client
	APIReader               client.Reader
	Config                  TenantControlPlaneReconcilerConfig
	TriggerChan             TenantControlPlaneChannel
	KamajiNamespace         string
	KamajiServiceAccount    string
	KamajiService           string
	KamajiMigrateImage      string
	MaxConcurrentReconciles int
	// CertificateChan is the channel used by the CertificateLifecycleController that is checking for
	// certificates and kubeconfig user certs validity: a generic event for the given TCP will be triggered
	// once the validity threshold for the given certificate is reached.
	CertificateChan CertificateChannel
	// contains filtered or unexported fields
}

TenantControlPlaneReconciler reconciles a TenantControlPlane object.

func (*TenantControlPlaneReconciler) Reconcile

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

func (*TenantControlPlaneReconciler) RemoveFinalizer

func (r *TenantControlPlaneReconciler) RemoveFinalizer(ctx context.Context, tenantControlPlane *kamajiv1alpha1.TenantControlPlane) error

func (*TenantControlPlaneReconciler) SetupWithManager

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

SetupWithManager sets up the controller with the Manager.

type TenantControlPlaneReconcilerConfig

type TenantControlPlaneReconcilerConfig struct {
	ReconcileTimeout     time.Duration
	DefaultDataStoreName string
	KineContainerImage   string
	TmpBaseDirectory     string
}

TenantControlPlaneReconcilerConfig gives the necessary configuration for TenantControlPlaneReconciler.