keda

Documentation

Index

• type ControllerBuilder
  • func NewControllerBuilder(apiClient *clients.Settings, name, nsname string) *ControllerBuilder
  • func PullController(apiClient *clients.Settings, name, nsname string) (*ControllerBuilder, error)
  • func (builder *ControllerBuilder) Create() (*ControllerBuilder, error)
  • func (builder *ControllerBuilder) Delete() (*ControllerBuilder, error)
  • func (builder *ControllerBuilder) Exists() bool
  • func (builder *ControllerBuilder) Get() (*kedav1alpha1.KedaController, error)
  • func (builder *ControllerBuilder) Update() (*ControllerBuilder, error)
  • func (builder *ControllerBuilder) WithAdmissionWebhooks(admissionWebhooks kedav1alpha1.KedaAdmissionWebhooksSpec) *ControllerBuilder
  • func (builder *ControllerBuilder) WithMetricsServer(metricsServer kedav1alpha1.KedaMetricsServerSpec) *ControllerBuilder
  • func (builder *ControllerBuilder) WithOperator(operator kedav1alpha1.KedaOperatorSpec) *ControllerBuilder
  • func (builder *ControllerBuilder) WithWatchNamespace(watchNamespace string) *ControllerBuilder
• type ScaledObjectBuilder
  • func NewScaledObjectBuilder(apiClient *clients.Settings, name, nsname string) *ScaledObjectBuilder
  • func PullScaledObject(apiClient *clients.Settings, name, nsname string) (*ScaledObjectBuilder, error)
  • func (builder *ScaledObjectBuilder) Create() (*ScaledObjectBuilder, error)
  • func (builder *ScaledObjectBuilder) Delete() (*ScaledObjectBuilder, error)
  • func (builder *ScaledObjectBuilder) Exists() bool
  • func (builder *ScaledObjectBuilder) Get() (*kedav2v1alpha1.ScaledObject, error)
  • func (builder *ScaledObjectBuilder) Update() (*ScaledObjectBuilder, error)
  • func (builder *ScaledObjectBuilder) WithCooldownPeriod(cooldownPeriod int32) *ScaledObjectBuilder
  • func (builder *ScaledObjectBuilder) WithMaxReplicaCount(maxReplicaCount int32) *ScaledObjectBuilder
  • func (builder *ScaledObjectBuilder) WithMinReplicaCount(minReplicaCount int32) *ScaledObjectBuilder
  • func (builder *ScaledObjectBuilder) WithPollingInterval(pollingInterval int32) *ScaledObjectBuilder
  • func (builder *ScaledObjectBuilder) WithScaleTargetRef(scaleTargetRef kedav2v1alpha1.ScaleTarget) *ScaledObjectBuilder
  • func (builder *ScaledObjectBuilder) WithTriggers(triggers []kedav2v1alpha1.ScaleTriggers) *ScaledObjectBuilder
• type TriggerAuthenticationBuilder
  • func NewTriggerAuthenticationBuilder(apiClient *clients.Settings, name, nsname string) *TriggerAuthenticationBuilder
  • func PullTriggerAuthentication(apiClient *clients.Settings, name, nsname string) (*TriggerAuthenticationBuilder, error)
  • func (builder *TriggerAuthenticationBuilder) Create() (*TriggerAuthenticationBuilder, error)
  • func (builder *TriggerAuthenticationBuilder) Delete() (*TriggerAuthenticationBuilder, error)
  • func (builder *TriggerAuthenticationBuilder) Exists() bool
  • func (builder *TriggerAuthenticationBuilder) Get() (*kedav2v1alpha1.TriggerAuthentication, error)
  • func (builder *TriggerAuthenticationBuilder) Update() (*TriggerAuthenticationBuilder, error)
  • func (builder *TriggerAuthenticationBuilder) WithSecretTargetRef(secretTargetRef []kedav2v1alpha1.AuthSecretTargetRef) *TriggerAuthenticationBuilder

Types

type ControllerBuilder

type ControllerBuilder struct {
	// KedaController definition, used to create the KedaController object.
	Definition *kedav1alpha1.KedaController
	// Created KedaController object.
	Object *kedav1alpha1.KedaController
	// contains filtered or unexported fields
}

ControllerBuilder provides a struct for KedaController object from the cluster and a KedaController definition.

func NewControllerBuilder

func NewControllerBuilder(
	apiClient *clients.Settings, name, nsname string) *ControllerBuilder

NewControllerBuilder creates a new instance of ControllerBuilder.

func PullController

func PullController(apiClient *clients.Settings, name, nsname string) (*ControllerBuilder, error)

PullController pulls existing kedaController from cluster.

func (*ControllerBuilder) Create

func (builder *ControllerBuilder) Create() (*ControllerBuilder, error)

Create makes a kedaController in the cluster and stores the created object in struct.

func (*ControllerBuilder) Delete

func (builder *ControllerBuilder) Delete() (*ControllerBuilder, error)

Delete removes kedaController from a cluster.

func (*ControllerBuilder) Exists

func (builder *ControllerBuilder) Exists() bool

Exists checks whether the given kedaController exists.

func (*ControllerBuilder) Get

func (builder *ControllerBuilder) Get() (*kedav1alpha1.KedaController, error)

Get fetches the defined kedaController from the cluster.

func (*ControllerBuilder) Update

func (builder *ControllerBuilder) Update() (*ControllerBuilder, error)

Update renovates the existing kedaController object with kedaController definition in builder.

func (*ControllerBuilder) WithAdmissionWebhooks

func (builder *ControllerBuilder) WithAdmissionWebhooks(
	admissionWebhooks kedav1alpha1.KedaAdmissionWebhooksSpec) *ControllerBuilder

WithAdmissionWebhooks sets the kedaController operator's profile.

func (*ControllerBuilder) WithMetricsServer

func (builder *ControllerBuilder) WithMetricsServer(
	metricsServer kedav1alpha1.KedaMetricsServerSpec) *ControllerBuilder

WithMetricsServer sets the kedaController operator's metricsServer.

func (*ControllerBuilder) WithOperator

func (builder *ControllerBuilder) WithOperator(
	operator kedav1alpha1.KedaOperatorSpec) *ControllerBuilder

WithOperator sets the kedaController operator's profile.

func (*ControllerBuilder) WithWatchNamespace

func (builder *ControllerBuilder) WithWatchNamespace(
	watchNamespace string) *ControllerBuilder

WithWatchNamespace sets the kedaController operator's watchNamespace.

type ScaledObjectBuilder

type ScaledObjectBuilder struct {
	// ScaledObject definition, used to create the ScaledObject object.
	Definition *kedav2v1alpha1.ScaledObject
	// Created ScaledObject object.
	Object *kedav2v1alpha1.ScaledObject
	// contains filtered or unexported fields
}

ScaledObjectBuilder provides a struct for ScaledObject object from the cluster and a ScaledObject definition.

func NewScaledObjectBuilder

func NewScaledObjectBuilder(
	apiClient *clients.Settings, name, nsname string) *ScaledObjectBuilder

NewScaledObjectBuilder creates a new instance of ScaledObjectBuilder.

func PullScaledObject

func PullScaledObject(apiClient *clients.Settings, name, nsname string) (*ScaledObjectBuilder, error)

PullScaledObject pulls existing scaledObject from cluster.

func (*ScaledObjectBuilder) Create

func (builder *ScaledObjectBuilder) Create() (*ScaledObjectBuilder, error)

Create makes a scaledObject in the cluster and stores the created object in struct.

func (*ScaledObjectBuilder) Delete

func (builder *ScaledObjectBuilder) Delete() (*ScaledObjectBuilder, error)

Delete removes scaledObject from a cluster.

func (*ScaledObjectBuilder) Exists

func (builder *ScaledObjectBuilder) Exists() bool

Exists checks whether the given scaledObject exists.

func (*ScaledObjectBuilder) Get

func (builder *ScaledObjectBuilder) Get() (*kedav2v1alpha1.ScaledObject, error)

Get fetches the defined scaledObject from the cluster.

func (*ScaledObjectBuilder) Update

func (builder *ScaledObjectBuilder) Update() (*ScaledObjectBuilder, error)

Update renovates the existing scaledObject object with scaledObject definition in builder.

func (*ScaledObjectBuilder) WithCooldownPeriod

func (builder *ScaledObjectBuilder) WithCooldownPeriod(
	cooldownPeriod int32) *ScaledObjectBuilder

WithCooldownPeriod sets the scaledObject operator's cooldownPeriod.

func (*ScaledObjectBuilder) WithMaxReplicaCount

func (builder *ScaledObjectBuilder) WithMaxReplicaCount(
	maxReplicaCount int32) *ScaledObjectBuilder

WithMaxReplicaCount sets the scaledObject operator's maxReplicaCount.

func (*ScaledObjectBuilder) WithMinReplicaCount

func (builder *ScaledObjectBuilder) WithMinReplicaCount(
	minReplicaCount int32) *ScaledObjectBuilder

WithMinReplicaCount sets the scaledObject operator's minReplicaCount.

func (*ScaledObjectBuilder) WithPollingInterval

func (builder *ScaledObjectBuilder) WithPollingInterval(
	pollingInterval int32) *ScaledObjectBuilder

WithPollingInterval sets the scaledObject operator's pollingInterval.

func (*ScaledObjectBuilder) WithScaleTargetRef

func (builder *ScaledObjectBuilder) WithScaleTargetRef(
	scaleTargetRef kedav2v1alpha1.ScaleTarget) *ScaledObjectBuilder

WithScaleTargetRef sets the scaledObject operator's scaleTargetRef.

func (*ScaledObjectBuilder) WithTriggers

func (builder *ScaledObjectBuilder) WithTriggers(
	triggers []kedav2v1alpha1.ScaleTriggers) *ScaledObjectBuilder

WithTriggers sets the scaledObject operator's maxReplicaCount.

type TriggerAuthenticationBuilder

type TriggerAuthenticationBuilder struct {
	// TriggerAuthentication definition, used to create the TriggerAuthentication object.
	Definition *kedav2v1alpha1.TriggerAuthentication
	// Created TriggerAuthentication object.
	Object *kedav2v1alpha1.TriggerAuthentication
	// contains filtered or unexported fields
}

TriggerAuthenticationBuilder provides a struct for TriggerAuthentication object from the cluster and a TriggerAuthentication definition.

func NewTriggerAuthenticationBuilder

func NewTriggerAuthenticationBuilder(
	apiClient *clients.Settings, name, nsname string) *TriggerAuthenticationBuilder

NewTriggerAuthenticationBuilder creates a new instance of TriggerAuthenticationBuilder.

func PullTriggerAuthentication

func PullTriggerAuthentication(apiClient *clients.Settings,
	name, nsname string) (*TriggerAuthenticationBuilder, error)

PullTriggerAuthentication pulls existing triggerAuthentication from cluster.

func (*TriggerAuthenticationBuilder) Create

func (builder *TriggerAuthenticationBuilder) Create() (*TriggerAuthenticationBuilder, error)

Create makes a triggerAuthentication in the cluster and stores the created object in struct.

func (*TriggerAuthenticationBuilder) Delete

func (builder *TriggerAuthenticationBuilder) Delete() (*TriggerAuthenticationBuilder, error)

Delete removes triggerAuthentication from a cluster.

func (*TriggerAuthenticationBuilder) Exists

func (builder *TriggerAuthenticationBuilder) Exists() bool

Exists checks whether the given triggerAuthentication exists.

func (*TriggerAuthenticationBuilder) Get

func (builder *TriggerAuthenticationBuilder) Get() (*kedav2v1alpha1.TriggerAuthentication, error)

Get fetches the defined triggerAuthentication from the cluster.

func (*TriggerAuthenticationBuilder) Update

func (builder *TriggerAuthenticationBuilder) Update() (*TriggerAuthenticationBuilder, error)

Update renovates the existing triggerAuthentication object with triggerAuthentication definition in builder.

func (*TriggerAuthenticationBuilder) WithSecretTargetRef

func (builder *TriggerAuthenticationBuilder) WithSecretTargetRef(
	secretTargetRef []kedav2v1alpha1.AuthSecretTargetRef) *TriggerAuthenticationBuilder

WithSecretTargetRef sets the triggerAuthentication operator's secretTargetRef.