predictor

Documentation

Index

• func DefaultPredictorsConfig(modelConfig predconf.AlgorithmModelConfig) map[predictionapi.AlgorithmType]Config
• type AlgorithmDataProviders
• type Config
• type Manager
  • func NewManager(realtimeProviders map[providers.DataSourceType]providers.RealTime, ...) Manager

Functions

func DefaultPredictorsConfig

func DefaultPredictorsConfig(modelConfig predconf.AlgorithmModelConfig) map[predictionapi.AlgorithmType]Config

DefaultPredictorsConfig will use all datasources you for real time and history provider. data proxy will select the first available. Now, for RealTimeProvider if you specified metricserver in command args, it is [metricserver,prom] in order, if not, it is [prom]. for HistoryProvider is [prom]

Types

type AlgorithmDataProviders

type AlgorithmDataProviders struct {
	// RealTimeProviders is names of realtime data providers. now support `prom`, `metricserver`
	RealTimeProviders []providers.DataSourceType
	// HistoryProviders is names of history data providers. now support only `prom`.
	HistoryProviders []providers.DataSourceType
}

type Config

type Config struct {
	DataProviders AlgorithmDataProviders
	ModelConfig   predconf.AlgorithmModelConfig
}

type Manager

type Manager interface {
	// Start start all predictors in manager, block until stopCh and all predictors exited
	Start(stopCh <-chan struct{})
	// GetPredictor return a registered predictor
	GetPredictor(predictor predictionapi.AlgorithmType) prediction.Interface
	// AddPredictorRealTimeProvider Dynamically add a real time data provider for a predictor
	AddPredictorRealTimeProvider(predictorName predictionapi.AlgorithmType, dataProviderName providers.DataSourceType, dataProvider providers.RealTime)
	// DeletePredictorRealTimeProvider Dynamically delete a real time data provider for a predictor
	DeletePredictorRealTimeProvider(predictorName predictionapi.AlgorithmType, dataProviderName providers.DataSourceType)
	// AddPredictorHistoryProvider Dynamically add a history data provider for a predictor
	AddPredictorHistoryProvider(predictorName predictionapi.AlgorithmType, dataProviderName providers.DataSourceType, dataProvider providers.History)
	// DeletePredictorHistoryProvider Dynamically delete a history data provider for a predictor
	DeletePredictorHistoryProvider(predictorName predictionapi.AlgorithmType, dataProviderName providers.DataSourceType)
}

func NewManager

func NewManager(realtimeProviders map[providers.DataSourceType]providers.RealTime,
	historyProviders map[providers.DataSourceType]providers.History, predictorsConfig map[predictionapi.AlgorithmType]Config) Manager