Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
var SupportedExtractors = []plugins.FeatureExtractor{ &vmware.VROpsHostsystemResolver{}, &vmware.VROpsProjectNoisinessExtractor{}, &vmware.VROpsHostsystemContentionExtractor{}, &kvm.NodeExporterHostCPUUsageExtractor{}, &kvm.NodeExporterHostMemoryActiveExtractor{}, &shared.FlavorHostSpaceExtractor{}, &shared.VMHostResidencyExtractor{}, &shared.VMLifeSpanExtractor{}, }
Configuration of feature extractors supported by the scheduler.
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]) GetName ¶
func (m FeatureExtractorMonitor[F]) GetName() string
Get the name of the wrapped feature extractor.
func (FeatureExtractorMonitor[F]) Init ¶
Initialize the wrapped feature extractor with the database and options.
func (FeatureExtractorMonitor[F]) Triggers ¶
func (m FeatureExtractorMonitor[F]) Triggers() []string
Get the message topics that trigger a re-execution of the wrapped feature extractor.
type FeatureExtractorPipeline ¶
type FeatureExtractorPipeline struct {
// contains filtered or unexported fields
}
Pipeline that contains multiple feature extractors and executes them.
func NewPipeline ¶
func NewPipeline(config conf.FeaturesConfig, database db.DB, m Monitor) FeatureExtractorPipeline
Create a new feature extractor pipeline with extractors contained in the configuration.
func (*FeatureExtractorPipeline) ExtractOnTrigger ¶
func (p *FeatureExtractorPipeline) ExtractOnTrigger()
Extract features from the data sources when triggered by MQTT messages. If mqtt is disabled, this function does nothing.
func (*FeatureExtractorPipeline) Init ¶
func (p *FeatureExtractorPipeline) Init(supportedExtractors []plugins.FeatureExtractor)
Initialize the feature extractors in the pipeline.
type Monitor ¶
type Monitor struct {
// contains filtered or unexported fields
}
Collection of Prometheus metrics to monitor feature extraction.
func NewPipelineMonitor ¶
func NewPipelineMonitor(registry *monitoring.Registry) Monitor
Create a new feature extraction monitor and register the necessary Prometheus metrics.
Source Files
Directories