controllers

Documentation

Index

• Constants
• func ClusterPredicates(logger logr.Logger) predicate.Funcs
• func ClusterSummaryPredicates(logger logr.Logger) predicate.Funcs
• func HealthCheckPredicates(logger logr.Logger) predicate.Funcs
• func HealthCheckReportPredicates(logger logr.Logger) predicate.Funcs
• func InitScheme() (*runtime.Scheme, error)
• func MachinePredicates(logger logr.Logger) predicate.Funcs
• func RegisterFeatures(d deployer.DeployerInterface, setupLog logr.Logger)
• func SetManagementRecorder(r record.EventRecorder)
• func SveltosClusterPredicates(logger logr.Logger) predicate.Funcs
• type ClusterHealthCheckReconciler
  • func (r *ClusterHealthCheckReconciler) Reconcile(ctx context.Context, req ctrl.Request) (_ ctrl.Result, reterr error)
  • func (r *ClusterHealthCheckReconciler) SetupWithManager(mgr ctrl.Manager) (controller.Controller, error)
  • func (r *ClusterHealthCheckReconciler) WatchForCAPI(mgr ctrl.Manager, c controller.Controller) error
• type ClusterReconciler
  • func (r *ClusterReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *ClusterReconciler) SetupWithManager(mgr ctrl.Manager) error
• type HealthCheckReconciler
  • func (r *HealthCheckReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *HealthCheckReconciler) SetupWithManager(mgr ctrl.Manager) error
• type ReloaderReportReconciler
  • func (r *ReloaderReportReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *ReloaderReportReconciler) SetupWithManager(mgr ctrl.Manager, collectionInterval int) error
• type ReportMode
• type SveltosClusterReconciler
  • func (r *SveltosClusterReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *SveltosClusterReconciler) SetupWithManager(mgr ctrl.Manager) error

Constants

const (
	// Namespace where reports will be generated
	ReportNamespace = "projectsveltos"
)

Functions

func ClusterPredicates

func ClusterPredicates(logger logr.Logger) predicate.Funcs

ClusterPredicates predicates for v1Cluster. ClusterHealthCheckReconciler watches v1Cluster events and react to those by reconciling itself based on following predicates

func ClusterSummaryPredicates

func ClusterSummaryPredicates(logger logr.Logger) predicate.Funcs

ClusterSummaryPredicates predicates for clustersummary. ClusterHealthCheckReconciler watches sveltos ClusterSummary events and react to those by reconciling itself based on following predicates

func HealthCheckPredicates

func HealthCheckPredicates(logger logr.Logger) predicate.Funcs

HealthCheckPredicates predicates for HealthCheck. ClusterHealthCheckReconciler watches sveltos HealthCheck events and react to those by reconciling itself based on following predicates

func HealthCheckReportPredicates

func HealthCheckReportPredicates(logger logr.Logger) predicate.Funcs

HealthCheckReportPredicates predicates for HealthCheckReport. ClusterHealthCheckReconciler watches sveltos HealthCheckReport events and react to those by reconciling itself based on following predicates

func InitScheme

func InitScheme() (*runtime.Scheme, error)

func MachinePredicates

func MachinePredicates(logger logr.Logger) predicate.Funcs

MachinePredicates predicates for v1Machine. ClusterHealthCheckReconciler watches v1Machine events and react to those by reconciling itself based on following predicates

func RegisterFeatures

func RegisterFeatures(d deployer.DeployerInterface, setupLog logr.Logger)

func SetManagementRecorder

func SetManagementRecorder(r record.EventRecorder)

func SveltosClusterPredicates

func SveltosClusterPredicates(logger logr.Logger) predicate.Funcs

SveltosClusterPredicates predicates for sveltos Cluster. ClusterHealthCheckReconciler watches sveltos Cluster events and react to those by reconciling itself based on following predicates

Types

type ClusterHealthCheckReconciler

type ClusterHealthCheckReconciler struct {
	client.Client
	Scheme               *runtime.Scheme
	ConcurrentReconciles int
	Deployer             deployer.DeployerInterface

	// use a Mutex to update Map as MaxConcurrentReconciles is higher than one
	Mux sync.Mutex

	// key: Sveltos/CAPI Cluster: value: set of all ClusterHealthCheck instances matching the Cluster
	ClusterMap map[corev1.ObjectReference]*libsveltosset.Set
	// key: ClusterHealthCheck: value: set of Sveltos/CAPI Clusters matched
	CHCToClusterMap map[types.NamespacedName]*libsveltosset.Set

	// key: ClusterHealthCheck; value ClusterHealthCheck Selector
	ClusterHealthChecks map[corev1.ObjectReference]libsveltosv1alpha1.Selector

	// For each cluster contains current labels
	// This is needed in following scenario:
	// - ClusterHealthCheck is created
	// - Cluster is created with labels matching ClusterHealthCheck
	// - When first control plane machine in such cluster becomes available
	// we need Cluster labels to know which ClusterHealthCheck to reconcile
	ClusterLabels map[corev1.ObjectReference]map[string]string

	// key: HealthCheck: value: set of all ClusterHealthCheck referencing it
	HealthCheckMap map[corev1.ObjectReference]*libsveltosset.Set

	// Key: ClusterHealthCheck: value: set of HealthChecks referenced
	CHCToHealthCheckMap map[types.NamespacedName]*libsveltosset.Set
}

ClusterHealthCheckReconciler reconciles a ClusterHealthCheck object

func (*ClusterHealthCheckReconciler) Reconcile

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

func (*ClusterHealthCheckReconciler) SetupWithManager

func (r *ClusterHealthCheckReconciler) SetupWithManager(mgr ctrl.Manager) (controller.Controller, error)

SetupWithManager sets up the controller with the Manager.

func (*ClusterHealthCheckReconciler) WatchForCAPI

func (r *ClusterHealthCheckReconciler) WatchForCAPI(mgr ctrl.Manager, c controller.Controller) error

type ClusterReconciler

type ClusterReconciler struct {
	client.Client
	Scheme *runtime.Scheme
}

ClusterReconciler reconciles a Cluster object

func (*ClusterReconciler) Reconcile

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

func (*ClusterReconciler) SetupWithManager

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

SetupWithManager sets up the controller with the Manager.

type HealthCheckReconciler

type HealthCheckReconciler struct {
	client.Client
	Scheme                *runtime.Scheme
	HealthCheckReportMode ReportMode
}

HealthCheckReconciler reconciles a HealthCheck object

func (*HealthCheckReconciler) Reconcile

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

+kubebuilder:rbac:groups=lib.projectsveltos.io,resources=healthchecks,verbs=get;list;watch;create;update;patch;delete +kubebuilder:rbac:groups=lib.projectsveltos.io,resources=healthchecks/status,verbs=get;update;patch +kubebuilder:rbac:groups=lib.projectsveltos.io,resources=healthchecks/finalizers,verbs=update

func (*HealthCheckReconciler) SetupWithManager

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

SetupWithManager sets up the controller with the Manager.

type ReloaderReportReconciler

type ReloaderReportReconciler struct {
	client.Client
	Scheme             *runtime.Scheme
	ReloaderReportMode ReportMode
}

ReloaderReportReconciler reconciles a ReloaderReport object

func (*ReloaderReportReconciler) Reconcile

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

func (*ReloaderReportReconciler) SetupWithManager

func (r *ReloaderReportReconciler) SetupWithManager(mgr ctrl.Manager, collectionInterval int) error

SetupWithManager sets up the controller with the Manager.

type ReportMode

type ReportMode int

const (
	// Default mode. In this mode, healthCheckManager running
	// in the management cluster periodically collects
	// HealthCheckReport from Sveltos/CAPI clusters
	CollectFromManagementCluster ReportMode = iota

	// In this mode, sveltos agent sends HealthCheckReport
	// to management cluster.
	// SveltosAgent is provided with Kubeconfig to access
	// management cluster and can only update HealthCheckReport (and ClassifierReport)
	AgentSendReportsNoGateway
)

type SveltosClusterReconciler

type SveltosClusterReconciler struct {
	client.Client
	Scheme *runtime.Scheme
}

SveltosClusterReconciler reconciles a SveltosCluster object

func (*SveltosClusterReconciler) Reconcile

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

func (*SveltosClusterReconciler) SetupWithManager

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

SetupWithManager sets up the controller with the Manager.