scaledjob

Documentation

Index

• func CalculateQueueLengthAndMaxValue(metrics []external_metrics.ExternalMetricValue, metricSpecs []v2.MetricSpec, ...) (queueLength, maxValue, targetAverageValue float64)
• func IsScaledJobActive(scalersMetrics []ScalerMetrics, multipleScalersCalculation string, ...) (bool, int64, int64, float64)
• type ScalerMetrics

Functions

func CalculateQueueLengthAndMaxValue

func CalculateQueueLengthAndMaxValue(metrics []external_metrics.ExternalMetricValue, metricSpecs []v2.MetricSpec, maxReplicaCount int64) (queueLength, maxValue, targetAverageValue float64)

CalculateQueueLengthAndMaxValue returns queueLength, maxValue, and targetAverageValue for the given metrics

func IsScaledJobActive

func IsScaledJobActive(scalersMetrics []ScalerMetrics, multipleScalersCalculation string, minReplicaCount, maxReplicaCount int64) (bool, int64, int64, float64)

IsScaledJobActive returns whether the input ScaledJob is active and queueLength and maxValue for scale

Types

type ScalerMetrics

type ScalerMetrics struct {
	QueueLength float64
	MaxValue    float64
	IsActive    bool
}