handler

Documentation

Index

• type ScaleHandler
  • func NewScaleHandler(client client.Client, reconcilerScheme *runtime.Scheme) *ScaleHandler
  • func (h *ScaleHandler) GetDeploymentScalers(scaledObject *kedav1alpha1.ScaledObject) ([]scalers.Scaler, *appsv1.Deployment, error)
  • func (h *ScaleHandler) HandleScaleLoop(ctx context.Context, scaledObject *kedav1alpha1.ScaledObject)

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(client client.Client, reconcilerScheme *runtime.Scheme) *ScaleHandler

NewScaleHandler creates a ScaleHandler object

func (*ScaleHandler) GetDeploymentScalers

func (h *ScaleHandler) GetDeploymentScalers(scaledObject *kedav1alpha1.ScaledObject) ([]scalers.Scaler, *appsv1.Deployment, error)

GetDeploymentScalers returns list of Scalers and Deployment for the specified ScaledObject

func (*ScaleHandler) HandleScaleLoop

func (h *ScaleHandler) HandleScaleLoop(ctx context.Context, scaledObject *kedav1alpha1.ScaledObject)

HandleScaleLoop blocks forever and checks the scaledObject based on its pollingInterval