Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type FeatureExtractorMonitor ¶
type FeatureExtractorMonitor[F plugins.FeatureExtractor] struct { // The wrapped feature extractor to monitor. FeatureExtractor F // contains filtered or unexported fields }
Wrapper for a feature extraction step that monitors the step's execution.
func (FeatureExtractorMonitor[F]) Extract ¶
func (m FeatureExtractorMonitor[F]) Extract() ([]plugins.Feature, error)
Run the wrapped feature extractor and measure the time it takes.
func (FeatureExtractorMonitor[F]) Init ¶
func (m FeatureExtractorMonitor[F]) Init(datasourceDB, extractorDB *db.DB, spec v1alpha1.KnowledgeSpec) error
Initialize the wrapped feature extractor with the database and options.
type KnowledgeReconciler ¶
type KnowledgeReconciler struct {
// Client for the kubernetes API.
client.Client
// Kubernetes scheme to use for the deschedulings.
Scheme *runtime.Scheme
// Monitor to use for tracking the reconciler.
Monitor Monitor
// Config for the reconciler.
Conf conf.Config
}
func (*KnowledgeReconciler) Reconcile ¶
Reconcile is part of the main kubernetes reconciliation loop which aims to move the current state of the cluster closer to the desired state.
func (*KnowledgeReconciler) SetupWithManager ¶
func (r *KnowledgeReconciler) SetupWithManager(mgr manager.Manager) error
type Monitor ¶
type Monitor struct {
// contains filtered or unexported fields
}
Collection of Prometheus metrics to monitor feature extraction.
func NewMonitor ¶
func NewMonitor() Monitor
func (*Monitor) Collect ¶
func (m *Monitor) Collect(ch chan<- prometheus.Metric)
func (*Monitor) Describe ¶
func (m *Monitor) Describe(ch chan<- *prometheus.Desc)
type TriggerReconciler ¶
type TriggerReconciler struct {
// Client for the kubernetes API.
client.Client
// Kubernetes scheme to use.
Scheme *runtime.Scheme
// Config for the reconciler.
Conf conf.Config
}
TriggerReconciler watches datasource and knowledge changes to trigger reconciliation of dependent knowledge resources based on recency requirements.
func (*TriggerReconciler) Reconcile ¶
Reconcile handles changes to datasource and knowledge resources and triggers reconciliation of dependent knowledge resources.
func (*TriggerReconciler) SetupWithManager ¶
func (r *TriggerReconciler) SetupWithManager(mgr manager.Manager) error
SetupWithManager sets up the controller with the Manager
Source Files
Directories