handler

Documentation

Index

• type ScaleHandler
  • func NewScaleHandler(kedaClient clientset.Interface, kubeClient kubernetes.Interface) *ScaleHandler
  • func (h *ScaleHandler) GetExternalMetricNames() []string
  • func (h *ScaleHandler) GetScaledObjectMetrics(namespace string, metricSelector labels.Selector, metricName string) ([]external_metrics.ExternalMetricValue, error)
  • func (h *ScaleHandler) HandleScaledObjectDelete(scaledObject *keda_v1alpha1.ScaledObject)
  • func (h *ScaleHandler) WatchScaledObjectWithContext(ctx context.Context, scaledObject *keda_v1alpha1.ScaledObject, isDue bool)

Types

type ScaleHandler

type ScaleHandler struct {
	// contains filtered or unexported fields
}

ScaleHandler encapsulates the logic of calling the right scalers for each ScaledObject and making the final scale decision and operation

func NewScaleHandler

func NewScaleHandler(kedaClient clientset.Interface, kubeClient kubernetes.Interface) *ScaleHandler

NewScaleHandler creates a ScaleHandler object

func (*ScaleHandler) GetExternalMetricNames

func (h *ScaleHandler) GetExternalMetricNames() []string

GetExternalMetricNames returns the exteral metrics of the triggers of the current scaled objects

func (*ScaleHandler) GetScaledObjectMetrics

func (h *ScaleHandler) GetScaledObjectMetrics(namespace string, metricSelector labels.Selector, metricName string) ([]external_metrics.ExternalMetricValue, error)

GetScaledObjectMetrics is used by the metric adapter in provider.go to get the value for a metric for a scaled object

func (*ScaleHandler) HandleScaledObjectDelete

func (h *ScaleHandler) HandleScaledObjectDelete(scaledObject *keda_v1alpha1.ScaledObject)

HandleScaledObjectDelete handles any cleanup when a scaled object is deleted

func (*ScaleHandler) WatchScaledObjectWithContext

func (h *ScaleHandler) WatchScaledObjectWithContext(ctx context.Context, scaledObject *keda_v1alpha1.ScaledObject, isDue bool)

TODO confusing naming switching from isUpdate (controller) -> isDue (here)[] WatchScaledObjectWithContext runs a handleScaleLoop go-routine for the scaledObject