Documentation
¶
Index ¶
Constants ¶
const ( // RequeueAfterError is the time to requeue the metric after an error RequeueAfterError = 2 * time.Minute )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type DataSinkCredentialsRetriever ¶
type DataSinkCredentialsRetriever struct {
// contains filtered or unexported fields
}
DataSinkCredentialsRetriever provides common functionality for retrieving DataSink credentials
func NewDataSinkCredentialsRetriever ¶
func NewDataSinkCredentialsRetriever(client client.Client, recorder record.EventRecorder) *DataSinkCredentialsRetriever
NewDataSinkCredentialsRetriever creates a new DataSinkCredentialsRetriever
func (*DataSinkCredentialsRetriever) GetDataSinkCredentials ¶
func (d *DataSinkCredentialsRetriever) GetDataSinkCredentials(ctx context.Context, dataSinkRef *v1alpha1.DataSinkReference, eventObject client.Object, l logr.Logger) (common.DataSinkCredentials, error)
GetDataSinkCredentials fetches DataSink configuration and credentials for any metric type
type FederatedManagedMetricReconciler ¶
type FederatedManagedMetricReconciler struct {
Scheme *runtime.Scheme
RestConfig *rest.Config
Recorder record.EventRecorder
// contains filtered or unexported fields
}
FederatedManagedMetricReconciler reconciles a FederatedManagedMetric object
func NewFederatedManagedMetricReconciler ¶
func NewFederatedManagedMetricReconciler(mgr ctrl.Manager) *FederatedManagedMetricReconciler
NewFederatedManagedMetricReconciler creates a new FederatedManagedMetricReconciler
func (*FederatedManagedMetricReconciler) Reconcile ¶
func (r *FederatedManagedMetricReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
Reconcile reads that state of the cluster for a FederatedManagedMetric object +kubebuilder:rbac:groups=metrics.openmcp.cloud,resources=federatedmanagedmetrics,verbs=get;list;watch;create;update;patch;delete +kubebuilder:rbac:groups=metrics.openmcp.cloud,resources=federatedmanagedmetrics/status,verbs=get;update;patch +kubebuilder:rbac:groups=metrics.openmcp.cloud,resources=federatedmanagedmetrics/finalizers,verbs=update +kubebuilder:rbac:groups=metrics.openmcp.cloud,resources=datasinks,verbs=get;list;watch +kubebuilder:rbac:groups="",resources=secrets,verbs=get
func (*FederatedManagedMetricReconciler) SetupWithManager ¶
func (r *FederatedManagedMetricReconciler) SetupWithManager(mgr ctrl.Manager) error
SetupWithManager sets up the controller with the Manager.
type FederatedMetricReconciler ¶
type FederatedMetricReconciler struct {
Scheme *runtime.Scheme
RestConfig *rest.Config
Recorder record.EventRecorder
// contains filtered or unexported fields
}
FederatedMetricReconciler reconciles a FederatedMetric object
func NewFederatedMetricReconciler ¶
func NewFederatedMetricReconciler(mgr ctrl.Manager) *FederatedMetricReconciler
NewFederatedMetricReconciler creates a new FederatedMetricReconciler
func (*FederatedMetricReconciler) Reconcile ¶
func (r *FederatedMetricReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
Reconcile handles the reconciliation of the FederatedMetric object
func (*FederatedMetricReconciler) SetupWithManager ¶
func (r *FederatedMetricReconciler) SetupWithManager(mgr ctrl.Manager) error
SetupWithManager sets up the controller with the Manager.
type InsightReconciler ¶
type InsightReconciler interface {
// contains filtered or unexported methods
}
InsightReconciler is an interface for the reconciler of Insight objects
type ManagedMetricReconciler ¶
type ManagedMetricReconciler struct {
Scheme *runtime.Scheme
Recorder record.EventRecorder
// contains filtered or unexported fields
}
ManagedMetricReconciler reconciles a ManagedMetric object
func NewManagedMetricReconciler ¶
func NewManagedMetricReconciler(mgr ctrl.Manager) *ManagedMetricReconciler
NewManagedMetricReconciler creates a new ManagedMetricReconciler
func (*ManagedMetricReconciler) Reconcile ¶
func (r *ManagedMetricReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
Reconcile is part of the main kubernetes reconciliation loop which aims to move the current state of the cluster closer to the desired state. For more details, check Reconcile and its Result here: - https://pkg.go.dev/sigs.k8s.io/controller-runtime@v0.16.3/pkg/reconcile
func (*ManagedMetricReconciler) SetupWithManager ¶
func (r *ManagedMetricReconciler) SetupWithManager(mgr ctrl.Manager) error
SetupWithManager sets up the controller with the Manager.
type MetricReconciler ¶
type MetricReconciler struct {
Scheme *runtime.Scheme
RestConfig *rest.Config
Recorder record.EventRecorder
// contains filtered or unexported fields
}
MetricReconciler reconciles a Metric object
func NewMetricReconciler ¶
func NewMetricReconciler(mgr ctrl.Manager) *MetricReconciler
NewMetricReconciler creates a new MetricReconciler
func (*MetricReconciler) SetupWithManager ¶
func (r *MetricReconciler) SetupWithManager(mgr ctrl.Manager) error
SetupWithManager sets up the controller with the Manager.
type OrchestratorFactory ¶
type OrchestratorFactory func(creds common.DataSinkCredentials, qConfig orchestrator.QueryConfig) *orchestrator.Orchestrator
OrchestratorFactory is a function type for creating orchestrators
type QueryConfigFactory ¶
type QueryConfigFactory func(ctx context.Context, rcaRef *v1alpha1.RemoteClusterAccessRef, r InsightReconciler) (orchestrator.QueryConfig, error)
QueryConfigFactory is a function type for creating query configs
Source Files