Documentation
¶
Index ¶
- Constants
- func ClusterPredicates(logger logr.Logger) predicate.Funcs
- func EventReportPredicates(logger logr.Logger) predicate.Funcs
- func EventSourcePredicates(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 SveltosClusterPredicates(logger logr.Logger) predicate.Funcs
- type ClusterReconciler
- type EventBasedAddOnReconciler
- func (r *EventBasedAddOnReconciler) Reconcile(ctx context.Context, req ctrl.Request) (_ ctrl.Result, reterr error)
- func (r *EventBasedAddOnReconciler) SetupWithManager(mgr ctrl.Manager) (controller.Controller, error)
- func (r *EventBasedAddOnReconciler) WatchForCAPI(mgr ctrl.Manager, c controller.Controller) error
- type EventSourceReconciler
- type ReportMode
- type SveltosClusterReconciler
Constants ¶
const (
// Namespace where reports will be generated
ReportNamespace = "projectsveltos"
)
Variables ¶
This section is empty.
Functions ¶
func ClusterPredicates ¶
ClusterPredicates predicates for v1Cluster. EventBasedAddOnReconciler watches v1Cluster events and react to those by reconciling itself based on following predicates
func EventReportPredicates ¶
EventReportPredicates predicates for EventReport. EventBasedAddOnReconciler watches sveltos EventReport events and react to those by reconciling itself based on following predicates
func EventSourcePredicates ¶
EventSourcePredicates predicates for EventSource. EventBasedAddOnReconciler watches sveltos EventSource events and react to those by reconciling itself based on following predicates
func InitScheme ¶
func MachinePredicates ¶
MachinePredicates predicates for v1Machine. EventBasedAddOnReconciler watches v1Machine events and react to those by reconciling itself based on following predicates
func RegisterFeatures ¶
func RegisterFeatures(d deployer.DeployerInterface, setupLog logr.Logger)
Types ¶
type ClusterReconciler ¶
ClusterReconciler reconciles a Cluster object
func (*ClusterReconciler) SetupWithManager ¶
func (r *ClusterReconciler) SetupWithManager(mgr ctrl.Manager) error
SetupWithManager sets up the controller with the Manager.
type EventBasedAddOnReconciler ¶
type EventBasedAddOnReconciler struct {
client.Client
Scheme *runtime.Scheme
ConcurrentReconciles int
Deployer deployer.DeployerInterface
EventReportMode ReportMode
// use a Mutex to update Map as MaxConcurrentReconciles is higher than one
Mux sync.Mutex
// key: Sveltos/CAPI Cluster: value: set of all EventBasedAddOn instances matching the Cluster
ClusterMap map[corev1.ObjectReference]*libsveltosset.Set
// key: EventBasedAddOn: value: set of Sveltos/CAPI Clusters matched
ToClusterMap map[types.NamespacedName]*libsveltosset.Set
// key: EventBasedAddOns; value EventBasedAddOn Selector
EventBasedAddOns map[corev1.ObjectReference]libsveltosv1alpha1.Selector
// For each cluster contains current labels
// This is needed in following scenario:
// - EventBasedAddOn is created
// - Cluster is created with labels matching EventBasedAddOn
// - When first control plane machine in such cluster becomes available
// we need Cluster labels to know which EventBasedAddOn to reconcile
ClusterLabels map[corev1.ObjectReference]map[string]string
// key: EventSource: value: set of all EventBasedAddOn referencing it
EventSourceMap map[corev1.ObjectReference]*libsveltosset.Set
// Key: EventBasedAddOn: value: set of EventSource referenced
ToEventSourceMap map[types.NamespacedName]*libsveltosset.Set
}
EventBasedAddOnReconciler reconciles a EventBasedAddOn object
func (*EventBasedAddOnReconciler) SetupWithManager ¶
func (r *EventBasedAddOnReconciler) SetupWithManager(mgr ctrl.Manager) (controller.Controller, error)
SetupWithManager sets up the controller with the Manager.
func (*EventBasedAddOnReconciler) WatchForCAPI ¶
func (r *EventBasedAddOnReconciler) WatchForCAPI(mgr ctrl.Manager, c controller.Controller) error
type EventSourceReconciler ¶
EventSourceReconciler reconciles a EventSource object
func (*EventSourceReconciler) Reconcile ¶
func (r *EventSourceReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
+kubebuilder:rbac:groups=lib.projectsveltos.io,resources=eventsources,verbs=get;list;watch;create;update;patch;delete +kubebuilder:rbac:groups=lib.projectsveltos.io,resources=eventsources/status,verbs=get;update;patch +kubebuilder:rbac:groups=lib.projectsveltos.io,resources=eventsources/finalizers,verbs=update
func (*EventSourceReconciler) SetupWithManager ¶
func (r *EventSourceReconciler) SetupWithManager(mgr ctrl.Manager) error
SetupWithManager sets up the controller with the Manager.
type ReportMode ¶
type ReportMode int
const ( // Default mode. In this mode, eventManager running // in the management cluster periodically collects // EventReports from Sveltos/CAPI clusters CollectFromManagementCluster ReportMode = iota // In this mode, sveltos agent sends EventReport // to management cluster. // SveltosAgent is provided with Kubeconfig to access // management cluster and can only update EventReport // (and ClassifierReport and HealthCheckReport). AgentSendReportsNoGateway )
type SveltosClusterReconciler ¶
SveltosClusterReconciler reconciles a SveltosCluster object
func (*SveltosClusterReconciler) SetupWithManager ¶
func (r *SveltosClusterReconciler) SetupWithManager(mgr ctrl.Manager) error
SetupWithManager sets up the controller with the Manager.