keda

Documentation

Index

• Constants
• Variables
• func GenerateScaledObject(obj metav1.Object, gvk schema.GroupVersionKind, ...) (*kedav1alpha1.ScaledObject, error)
• func GetInt32ValueFromMap(dict map[string]string, key string, defaultValue int32) (*int32, error)
• func SupportedCRD(gvk schema.GroupVersionKind) bool

Constants

const (
	// Autoscaling refers to the autoscaling group.
	Autoscaling = "autoscaling.knative.dev"

	// AutoscalingClassAnnotation is the annotation for the explicit class of
	// scaler that a particular resource has opted into.
	AutoscalingClassAnnotation = Autoscaling + "/class"

	// AutoscalingMinScaleAnnotation is the annotation to specify the minimum number of replicas to scale down to.
	AutoscalingMinScaleAnnotation = Autoscaling + "/minScale"
	// AutoscalingMaxScaleAnnotation is the annotation to specify the maximum number of replicas to scale out to.
	AutoscalingMaxScaleAnnotation = Autoscaling + "/maxScale"

	// KEDA is Keda autoscaler.
	KEDA = "keda.autoscaling.knative.dev"

	// KedaAutoscalingPollingIntervalAnnotation is the annotation that refers to the interval in seconds KEDA
	// uses to poll metrics in order to inform its scaling decisions.
	KedaAutoscalingPollingIntervalAnnotation = KEDA + "/pollingInterval"
	// KedaAutoscalingCooldownPeriodAnnotation is the annotation that refers to the period KEDA waits until it
	// scales a Deployment down.
	KedaAutoscalingCooldownPeriodAnnotation = KEDA + "/cooldownPeriod"

	// KedaAutoscalingKafkaLagThreshold is the annotation that refers to the lag on the current consumer group that's used for scaling (1<->N)
	KedaAutoscalingKafkaLagThreshold = KEDA + "/kafkaLagThreshold"

	// KedaAutoscalingKafkaActivationLagThreshold is the annotation that refers to the lag on the current consumer group that's used for activation (0<->1)
	KedaAutoscalingKafkaActivationLagThreshold = KEDA + "/kafkaActivationLagThreshold"

	// KedaAutoscalingRabbitMQQueueLength is the annotation that refers to the target value for number of messages in a RabbitMQ brokers
	// trigger queue.
	KedaAutoscalingRabbitMQQueueLength = KEDA + "/rabbitMQQueueLength"

	// KedaAutoscalingRedisStreamPendingEntriesCount is the annotation that refers to the target value for number of entries in the Pending Entries List
	// for the specified consumer group in the Redis Stream.
	KedaAutoscalingRedisStreamPendingEntriesCount = KEDA + "/redisStreamPendingEntriesCount"
)

Variables

var (
	KedaSchemeGroupVersion = schema.GroupVersion{Group: "keda.sh", Version: "v1alpha1"}
)

Functions

func GenerateScaledObject

func GenerateScaledObject(obj metav1.Object, gvk schema.GroupVersionKind, scaleTarget *kedav1alpha1.ScaleTarget, triggers []kedav1alpha1.ScaleTriggers) (*kedav1alpha1.ScaledObject, error)

func GetInt32ValueFromMap

func GetInt32ValueFromMap(dict map[string]string, key string, defaultValue int32) (*int32, error)

func SupportedCRD

func SupportedCRD(gvk schema.GroupVersionKind) bool