timeseriesprediction

Documentation

Index

• func CommonTimeSeries2ApiTimeSeries(tsList []*common.TimeSeries) predictionapi.MetricTimeSeriesList
• func ExistsPredictionMetric(metric predictionapi.PredictionMetric, ...) bool
• func GetTimeSeriesPredictionKey(tsp *predictionapi.TimeSeriesPrediction) string
• func IsWindowInSamples(start, end time.Time, samples []predictionapi.Sample) bool
• type Controller
  • func NewController(client client.Client, recorder record.EventRecorder, ...) *Controller
  • func (tc *Controller) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (tc *Controller) SetupWithManager(mgr ctrl.Manager, maxConcurrentReconciles int) error
  • func (tc *Controller) UpdateStatus(ctx context.Context, tsPrediction *predictionapi.TimeSeriesPrediction, ...) error
• type MetricContext
  • func NewMetricContext(fetcher target.SelectorFetcher, ...) (*MetricContext, error)
  • func (c *MetricContext) ConvertApiMetric2InternalConfig(metric *predictionapi.PredictionMetric) *predconf.Config
  • func (c *MetricContext) ConvertApiMetrics2InternalConfigs(metrics []predictionapi.PredictionMetric) []*predconf.Config
  • func (c *MetricContext) DeleteApiConfig(conf *predictionapi.PredictionMetric)
  • func (c *MetricContext) DeleteApiConfigs(configs []predictionapi.PredictionMetric)
  • func (c *MetricContext) GetCaller() string
  • func (c *MetricContext) GetMetricNamer(conf *predictionapi.PredictionMetric) metricnaming.MetricNamer
  • func (c *MetricContext) ResourceToMetricNamer(resourceName *corev1.ResourceName, caller string) metricnaming.GeneralMetricNamer
  • func (c *MetricContext) WithApiConfig(conf *predictionapi.PredictionMetric)
  • func (c *MetricContext) WithApiConfigs(configs []predictionapi.PredictionMetric)

Functions

func CommonTimeSeries2ApiTimeSeries

func CommonTimeSeries2ApiTimeSeries(tsList []*common.TimeSeries) predictionapi.MetricTimeSeriesList

func ExistsPredictionMetric

func ExistsPredictionMetric(metric predictionapi.PredictionMetric, metrics []predictionapi.PredictionMetric) bool

func GetTimeSeriesPredictionKey

func GetTimeSeriesPredictionKey(tsp *predictionapi.TimeSeriesPrediction) string

func IsWindowInSamples

func IsWindowInSamples(start, end time.Time, samples []predictionapi.Sample) bool

Types

type Controller

type Controller struct {
	client.Client
	Recorder      record.EventRecorder
	UpdatePeriod  time.Duration
	TargetFetcher target.SelectorFetcher
	Scheme        *runtime.Scheme
	RestMapper    meta.RESTMapper
	ScaleClient   scale.ScalesGetter
	// contains filtered or unexported fields
}

func NewController

func NewController(
	client client.Client,
	recorder record.EventRecorder,
	updatePeriod time.Duration,
	predictorMgr predictormgr.Manager,
	targetFetcher target.SelectorFetcher,
) *Controller

func (*Controller) Reconcile

func (tc *Controller) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

Reconcile reconcile the time series prediction

func (*Controller) SetupWithManager

func (tc *Controller) SetupWithManager(mgr ctrl.Manager, maxConcurrentReconciles int) error

SetupWithManager creates a controller and register to controller manager.

func (*Controller) UpdateStatus

func (tc *Controller) UpdateStatus(ctx context.Context, tsPrediction *predictionapi.TimeSeriesPrediction, newStatus *predictionapi.TimeSeriesPredictionStatus) error

type MetricContext

type MetricContext struct {
	Namespace        string
	TargetKind       string
	Name             string
	APIVersion       string
	Selector         labels.Selector
	SeriesPrediction *predictionapi.TimeSeriesPrediction
	// contains filtered or unexported fields
}

func NewMetricContext

func NewMetricContext(fetcher target.SelectorFetcher, seriesPrediction *predictionapi.TimeSeriesPrediction, predictorMgr predictormgr.Manager) (*MetricContext, error)

func (*MetricContext) ConvertApiMetric2InternalConfig

func (c *MetricContext) ConvertApiMetric2InternalConfig(metric *predictionapi.PredictionMetric) *predconf.Config

ConvertApiMetric2InternalConfig

func (*MetricContext) ConvertApiMetrics2InternalConfigs

func (c *MetricContext) ConvertApiMetrics2InternalConfigs(metrics []predictionapi.PredictionMetric) []*predconf.Config

ConvertApiMetrics2InternalConfigs

func (*MetricContext) DeleteApiConfig

func (c *MetricContext) DeleteApiConfig(conf *predictionapi.PredictionMetric)

func (*MetricContext) DeleteApiConfigs

func (c *MetricContext) DeleteApiConfigs(configs []predictionapi.PredictionMetric)

func (*MetricContext) GetCaller

func (c *MetricContext) GetCaller() string

func (*MetricContext) GetMetricNamer

func (c *MetricContext) GetMetricNamer(conf *predictionapi.PredictionMetric) metricnaming.MetricNamer

func (*MetricContext) ResourceToMetricNamer

func (c *MetricContext) ResourceToMetricNamer(resourceName *corev1.ResourceName, caller string) metricnaming.GeneralMetricNamer

func (*MetricContext) WithApiConfig

func (c *MetricContext) WithApiConfig(conf *predictionapi.PredictionMetric)

func (*MetricContext) WithApiConfigs

func (c *MetricContext) WithApiConfigs(configs []predictionapi.PredictionMetric)