controllers

Apr 17, 2025

Changes in this version

+ func SetAgentInMgmtCluster(isInMgmtCluster bool)

Mar 10, 2025

Changes in this version

+ func SetDriftDetectionRegistry(reg string)

Feb 25, 2025

Changes in this version

+ func SetCAPIOnboardAnnotation(key string)

Feb 19, 2025

Changes in this version

+ type SortedCorev1ObjectReference []corev1.ObjectReference

+ func (a SortedCorev1ObjectReference) Len() int

+ func (a SortedCorev1ObjectReference) Less(i, j int) bool

+ func (a SortedCorev1ObjectReference) Swap(i, j int)

+ type SortedHelmCharts []configv1beta1.HelmChart

+ func (a SortedHelmCharts) Len() int

+ func (a SortedHelmCharts) Less(i, j int) bool

+ func (a SortedHelmCharts) Swap(i, j int)

+ type SortedKustomizationRefs []configv1beta1.KustomizationRef

+ func (a SortedKustomizationRefs) Len() int

+ func (a SortedKustomizationRefs) Less(i, j int) bool

+ func (a SortedKustomizationRefs) Swap(i, j int)

Jan 30, 2025

Changes in this version

+ func SetLuaConfigMap(name string)

Sep 10, 2024

Changes in this version

type ClusterSummaryReconciler

+ Version string

Jul 11, 2024

Changes in this version

+ func SetDriftdetectionConfigMap(name string)

Jul 3, 2024

Changes in this version

+ func ExtraFuncMap() template.FuncMap

+ type CustomPatchPostRenderer struct

+ Patches []configv1beta1.Patch

+ func (k *CustomPatchPostRenderer) Run(renderedManifests *bytes.Buffer) (modifiedManifests *bytes.Buffer, err error)

+ func (k *CustomPatchPostRenderer) RunUnstructured(unstructuredObjs []*unstructured.Unstructured) ([]*unstructured.Unstructured, error)

May 16, 2024

Changes in this version

type ClusterSummaryReconciler

+ ConflictRetryTime time.Duration

May 6, 2024

Changes in this version

+ type ClusterPredicate struct

+ Logger logr.Logger

+ func (c ClusterPredicate) Generic(obj event.TypedGenericEvent[*clusterv1.Cluster]) bool

+ func (p ClusterPredicate) Create(obj event.TypedCreateEvent[*clusterv1.Cluster]) bool

+ func (p ClusterPredicate) Delete(obj event.TypedDeleteEvent[*clusterv1.Cluster]) bool

+ func (p ClusterPredicate) Update(obj event.TypedUpdateEvent[*clusterv1.Cluster]) bool

+ type FluxBucketPredicate struct

+ Logger logr.Logger

+ func (p FluxBucketPredicate) Create(obj event.TypedCreateEvent[*sourcev1b2.Bucket]) bool

+ func (p FluxBucketPredicate) Delete(obj event.TypedDeleteEvent[*sourcev1b2.Bucket]) bool

+ func (p FluxBucketPredicate) Generic(obj event.TypedGenericEvent[*sourcev1b2.Bucket]) bool

+ func (p FluxBucketPredicate) Update(obj event.TypedUpdateEvent[*sourcev1b2.Bucket]) bool

+ type FluxGitRepositoryPredicate struct

+ Logger logr.Logger

+ func (p FluxGitRepositoryPredicate) Create(obj event.TypedCreateEvent[*sourcev1.GitRepository]) bool

+ func (p FluxGitRepositoryPredicate) Delete(obj event.TypedDeleteEvent[*sourcev1.GitRepository]) bool

+ func (p FluxGitRepositoryPredicate) Generic(obj event.TypedGenericEvent[*sourcev1.GitRepository]) bool

+ func (p FluxGitRepositoryPredicate) Update(obj event.TypedUpdateEvent[*sourcev1.GitRepository]) bool

+ type FluxOCIRepositoryPredicate struct

+ Logger logr.Logger

+ func (p FluxOCIRepositoryPredicate) Create(obj event.TypedCreateEvent[*sourcev1b2.OCIRepository]) bool

+ func (p FluxOCIRepositoryPredicate) Delete(obj event.TypedDeleteEvent[*sourcev1b2.OCIRepository]) bool

+ func (p FluxOCIRepositoryPredicate) Generic(obj event.TypedGenericEvent[*sourcev1b2.OCIRepository]) bool

+ func (p FluxOCIRepositoryPredicate) Update(obj event.TypedUpdateEvent[*sourcev1b2.OCIRepository]) bool

+ type MachinePredicate struct

+ Logger logr.Logger

+ func (p MachinePredicate) Create(obj event.TypedCreateEvent[*clusterv1.Machine]) bool

+ func (p MachinePredicate) Delete(obj event.TypedDeleteEvent[*clusterv1.Machine]) bool

+ func (p MachinePredicate) Generic(obj event.TypedGenericEvent[*clusterv1.Machine]) bool

+ func (p MachinePredicate) Update(obj event.TypedUpdateEvent[*clusterv1.Machine]) bool

Apr 4, 2024

Changes in this version

type ClusterProfileReconciler

+ Logger logr.Logger

type ClusterSetReconciler

+ Logger logr.Logger

type ClusterSummaryReconciler

+ Logger logr.Logger

type ProfileReconciler

+ Logger logr.Logger

type SetReconciler

+ Logger logr.Logger

Mar 14, 2024

Changes in this version

+ func SetPredicates(logger logr.Logger) predicate.Funcs

type ClusterProfileReconciler

+ ClusterSetMap map[corev1.ObjectReference]*libsveltosset.Set

+ func (r *ClusterProfileReconciler) GetController() controller.Controller

+ type ClusterSetReconciler struct

+ ClusterLabels map[corev1.ObjectReference]map[string]string

+ ClusterMap map[corev1.ObjectReference]*libsveltosset.Set

+ ClusterSetMap map[corev1.ObjectReference]*libsveltosset.Set

+ ClusterSets map[corev1.ObjectReference]libsveltosv1alpha1.Selector

+ ConcurrentReconciles int

+ Mux sync.Mutex

+ Scheme *runtime.Scheme

+ func (r *ClusterSetReconciler) GetController() controller.Controller

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

+ func (r *ClusterSetReconciler) SetupWithManager(mgr ctrl.Manager) error

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

type ClusterSummaryReconciler

+ func (r *ClusterSummaryReconciler) GetController() controller.Controller

type ProfileReconciler

+ SetMap map[corev1.ObjectReference]*libsveltosset.Set

+ func (r *ProfileReconciler) GetController() controller.Controller

+ type SetReconciler struct

+ ClusterLabels map[corev1.ObjectReference]map[string]string

+ ClusterMap map[corev1.ObjectReference]*libsveltosset.Set

+ ConcurrentReconciles int

+ Mux sync.Mutex

+ Scheme *runtime.Scheme

+ SetMap map[corev1.ObjectReference]*libsveltosset.Set

+ Sets map[corev1.ObjectReference]libsveltosv1alpha1.Selector

+ func (r *SetReconciler) GetController() controller.Controller

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

+ func (r *SetReconciler) SetupWithManager(mgr ctrl.Manager) error

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

Jan 25, 2024

Changes in this version

+ func SetVersion(v string)

+ type NonRetriableError struct

+ Message string

+ func (r *NonRetriableError) Error() string

Jan 3, 2024

Changes in this version

+ const ProfileLabelName

+ type ProfileReconciler struct

+ ClusterLabels map[corev1.ObjectReference]map[string]string

+ ClusterMap map[corev1.ObjectReference]*libsveltosset.Set

+ ConcurrentReconciles int

+ Mux sync.Mutex

+ ProfileMap map[corev1.ObjectReference]*libsveltosset.Set

+ Profiles map[corev1.ObjectReference]libsveltosv1alpha1.Selector

+ Scheme *runtime.Scheme

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

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

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

Oct 28, 2023

Changes in this version

type ClusterSummaryReconciler

+ ShardKey string

Oct 7, 2023

Changes in this version

type ClusterSummaryReconciler

+ AgentInMgmtCluster bool

Jul 4, 2023

Changes in this version

+ const ClusterProfileLabelName

+ const ClusterSummaryLabelName

+ const PolicyTemplate

+ var CreateFuncTrue = func(e event.CreateEvent, logger logr.Logger) bool

+ var DeleteFuncTrue = func(e event.DeleteEvent, logger logr.Logger) bool

+ var GenericFuncFalse = func(e event.GenericEvent, logger logr.Logger) bool

+ func ClusterPredicates(logger logr.Logger) predicate.Funcs

+ func ConfigMapPredicates(logger logr.Logger) predicate.Funcs

+ func FluxSourcePredicates(logger logr.Logger) predicate.Funcs

+ func GetClusterSummaryName(clusterProfileName, clusterName string, isSveltosCluster bool) string

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

+ func MachinePredicates(logger logr.Logger) predicate.Funcs

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

+ func SecretPredicates(logger logr.Logger) predicate.Funcs

+ func SetManagementClusterAccess(c client.Client, config *rest.Config)

+ func SveltosClusterPredicates(logger logr.Logger) predicate.Funcs

+ type ClusterProfileReconciler struct

+ ClusterLabels map[corev1.ObjectReference]map[string]string

+ ClusterMap map[corev1.ObjectReference]*libsveltosset.Set

+ ClusterProfileMap map[corev1.ObjectReference]*libsveltosset.Set

+ ClusterProfiles map[corev1.ObjectReference]libsveltosv1alpha1.Selector

+ ConcurrentReconciles int

+ Mux sync.Mutex

+ Scheme *runtime.Scheme

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

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

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

+ type ClusterSummaryReconciler struct

+ ClusterMap map[corev1.ObjectReference]*libsveltosset.Set

+ ClusterSummaryMap map[types.NamespacedName]*libsveltosset.Set

+ ConcurrentReconciles int

+ Deployer deployer.DeployerInterface

+ PolicyMux sync.Mutex

+ ReferenceMap map[corev1.ObjectReference]*libsveltosset.Set

+ ReportMode ReportMode

+ Scheme *runtime.Scheme

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

+ func (r *ClusterSummaryReconciler) SetupWithManager(ctx context.Context, mgr ctrl.Manager) (controller.Controller, error)

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

+ func (r *ClusterSummaryReconciler) WatchForFlux(mgr ctrl.Manager, c controller.Controller) error

+ type ReportMode int

+ const AgentSendUpdatesNoGateway

+ const CollectFromManagementCluster