keda

Documentation

Index

• Constants
• Variables
• func GenerateScaleTarget(cg *kafkainternals.ConsumerGroup) *kedav1alpha1.ScaleTarget
• func GenerateScaleTriggers(cg *kafkainternals.ConsumerGroup, ...) ([]kedav1alpha1.ScaleTriggers, error)
• func GenerateScaledObject(obj metav1.Object, gvk schema.GroupVersionKind, ...) (*kedav1alpha1.ScaledObject, error)
• func GenerateScaledObjectName(obj metav1.Object) string
• func GenerateTriggerAuthentication(cg *kafkainternals.ConsumerGroup, secretData map[string][]byte) (*kedav1alpha1.TriggerAuthentication, *corev1.Secret, error)
• func GetInt32ValueFromMap(dict map[string]string, key string, defaultValue int32) (*int32, error)
• func IsEnabled(ctx context.Context, features *config.KafkaFeatureFlags, ...) bool
• func SetAutoscalingAnnotations(objAnnotations map[string]string) map[string]string

Constants

const (
	// AutoscalerClass is the KEDA autoscaler class.
	AutoscalerClass = "keda.autoscaling.knative.dev"
)

Variables

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

Functions

func GenerateScaleTarget

func GenerateScaleTarget(cg *kafkainternals.ConsumerGroup) *kedav1alpha1.ScaleTarget

func GenerateScaleTriggers

func GenerateScaleTriggers(cg *kafkainternals.ConsumerGroup, triggerAuthentication *kedav1alpha1.TriggerAuthentication, aconfig autoscaler.AutoscalerConfig) ([]kedav1alpha1.ScaleTriggers, error)

func GenerateScaledObject

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

func GenerateScaledObjectName

func GenerateScaledObjectName(obj metav1.Object) string

func GenerateTriggerAuthentication

func GenerateTriggerAuthentication(cg *kafkainternals.ConsumerGroup, secretData map[string][]byte) (*kedav1alpha1.TriggerAuthentication, *corev1.Secret, error)

func GetInt32ValueFromMap

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

func IsEnabled

func IsEnabled(ctx context.Context, features *config.KafkaFeatureFlags, client versioned.Interface, object metav1.Object) bool

func SetAutoscalingAnnotations

func SetAutoscalingAnnotations(objAnnotations map[string]string) map[string]string