autoscaler

Documentation

Index

• func MainAutoscalingLoop(client *clients.Client, extensionsClient *kubernetes.Clientset)
• func ScrapeExogenousMetrics(metric model.AutoscalingDefinitionMetric, testDuration time.Duration, ...) (exogenousRegressorResultChannel chan ExogenousRegressorScrapeResult, ...)
• func StartAutoscaleProcess(autoscaleEvaluationChannel chan AutoscaleEvaluation, ...)
• type AutoscaleEvaluation
• type AutoscaleEvaluationResult
  • func EvaluateAutoscaling(resultChannel metrics.TestResultsChannel, ...) AutoscaleEvaluationResult
  • func EvaluateAutoscalingPredictive(resultChannel metrics.TestResultsChannel, ...) AutoscaleEvaluationResult
  • func EvaluateAutoscalingReactive(resultChannel metrics.TestResultsChannel, ...) AutoscaleEvaluationResult
• type DefinitionChanges
• type DefinitionChannel
• type ExogenousRegressorResultChannel
  • func CollectExogenousMetrics(metric model.AutoscalingDefinitionMetric) (ExogenousRegressorResultChannel, error)
• type ExogenousRegressorScrapeResult
• type MetricChannels
• type ScrapeResultMap
• type ScrapedMetricItem

Functions

func MainAutoscalingLoop

func MainAutoscalingLoop(client *clients.Client, extensionsClient *kubernetes.Clientset)

func ScrapeExogenousMetrics

func ScrapeExogenousMetrics(metric model.AutoscalingDefinitionMetric, testDuration time.Duration, scrapeDuration time.Duration) (exogenousRegressorResultChannel chan ExogenousRegressorScrapeResult, scrapeInterval chan bool)

func StartAutoscaleProcess

func StartAutoscaleProcess(autoscaleEvaluationChannel chan AutoscaleEvaluation, client *kubernetes.Clientset,
	definition model.AutoscalingDefinition, clearMetricBufferChannel chan model.AutoscalingDefinitionMetric)

Types

type AutoscaleEvaluation

type AutoscaleEvaluation struct {
	ScaleDown bool
	ScaleUp   bool
	Metric    model.AutoscalingDefinitionMetric
}

type AutoscaleEvaluationResult

type AutoscaleEvaluationResult struct {
	AutoscaleEvaluation           chan AutoscaleEvaluation
	CloseEvaluationProcessChannel chan bool
	ClearBufferChannel            chan bool
}

func EvaluateAutoscaling

func EvaluateAutoscaling(resultChannel metrics.TestResultsChannel,
	exogenousRegressorResultChannel chan ExogenousRegressorScrapeResult,
	metric model.AutoscalingDefinitionMetric) AutoscaleEvaluationResult

func EvaluateAutoscalingPredictive

func EvaluateAutoscalingPredictive(
	resultChannel metrics.TestResultsChannel,
	exogenousRegressorResultChannel chan ExogenousRegressorScrapeResult,
	metric model.AutoscalingDefinitionMetric) AutoscaleEvaluationResult

func EvaluateAutoscalingReactive

func EvaluateAutoscalingReactive(
	resultChannel metrics.TestResultsChannel,
	metric model.AutoscalingDefinitionMetric) AutoscaleEvaluationResult

type DefinitionChanges

type DefinitionChanges struct {
	// contains filtered or unexported fields
}

type DefinitionChannel

type DefinitionChannel struct {
	// contains filtered or unexported fields
}

type ExogenousRegressorResultChannel

type ExogenousRegressorResultChannel struct {
	// contains filtered or unexported fields
}

func CollectExogenousMetrics

func CollectExogenousMetrics(metric model.AutoscalingDefinitionMetric) (ExogenousRegressorResultChannel, error)

type ExogenousRegressorScrapeResult

type ExogenousRegressorScrapeResult struct {
	Name    string
	Value   float64
	IsValid bool
}

type MetricChannels

type MetricChannels struct {
	// contains filtered or unexported fields
}

type ScrapeResultMap

type ScrapeResultMap struct {
	Name        string
	ScrapedList []ScrapedMetricItem
}

type ScrapedMetricItem

type ScrapedMetricItem struct {
	MetricName    string
	IsMetricValid bool
	Value         []model2.Value
}