duck

Documentation

Overview

Package duck contains Cloud Run Events API versions for duck components

Package duck contains Cloud Run Events API versions for duck components

Package duck contains Cloud Run Events API versions for duck components

Index

• Constants
• func CheckImmutableClusterNameAnnotation(current *metav1.ObjectMeta, original *metav1.ObjectMeta, errs *apis.FieldError) *apis.FieldError
• func SetAutoscalingAnnotationsDefaults(ctx context.Context, obj *metav1.ObjectMeta)
• func SetClusterNameAnnotation(obj *metav1.ObjectMeta, client metadataClient.Client)
• func ValidateAutoscalingAnnotations(ctx context.Context, annotations map[string]string, errs *apis.FieldError) *apis.FieldError

Constants

const (
	GroupName = "duck.cloud.google.com"

	// 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"
	// ClusterNameAnnotation is the annotation for the cluster Name.
	ClusterNameAnnotation = "cluster-name"

	// AutoscalingMinScaleAnnotation is the annotation to specify the minimum number of pods to scale to.
	AutoscalingMinScaleAnnotation = Autoscaling + "/minScale"
	// AutoscalingMaxScaleAnnotation is the annotation to specify the maximum number of pods to scale 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"
	// KedaAutoscalingSubscriptionSizeAnnotation is the annotation that refers to the size of unacked messages in a
	// Pub/Sub subscription that Keda uses in order to decide when and by how much to scale out.
	KedaAutoscalingSubscriptionSizeAnnotation = KEDA + "/subscriptionSize"
)

Functions

func CheckImmutableClusterNameAnnotation

func CheckImmutableClusterNameAnnotation(current *metav1.ObjectMeta, original *metav1.ObjectMeta, errs *apis.FieldError) *apis.FieldError

CheckImmutableClusterNameAnnotation checks non-empty cluster-name annotation is immutable.

func SetAutoscalingAnnotationsDefaults

func SetAutoscalingAnnotationsDefaults(ctx context.Context, obj *metav1.ObjectMeta)

func SetClusterNameAnnotation

func SetClusterNameAnnotation(obj *metav1.ObjectMeta, client metadataClient.Client)

SetClusterNameAnnotation sets the cluster-name annotation when running on GKE or GCE.

func ValidateAutoscalingAnnotations

func ValidateAutoscalingAnnotations(ctx context.Context, annotations map[string]string, errs *apis.FieldError) *apis.FieldError

ValidateAutoscalingAnnotations validates the autoscaling annotations. The class ensures that we reconcile using the corresponding controller.