executor

Documentation

Index

• func GetPausedReplicaCount(scaledObject *kedav1alpha1.ScaledObject) (*int32, error)
• type ScaleExecutor
  • func NewScaleExecutor(client runtimeclient.Client, scaleClient scale.ScalesGetter, ...) ScaleExecutor
• type ScaleExecutorOptions
• type ScalingStrategy
  • func NewScalingStrategy(logger logr.Logger, scaledJob *kedav1alpha1.ScaledJob) ScalingStrategy

Functions

func GetPausedReplicaCount

func GetPausedReplicaCount(scaledObject *kedav1alpha1.ScaledObject) (*int32, error)

GetPausedReplicaCount returns the paused replica count of the ScaledObject. If not paused, it returns nil.

Types

type ScaleExecutor

type ScaleExecutor interface {
	RequestJobScale(ctx context.Context, scaledJob *kedav1alpha1.ScaledJob, isActive bool, isError bool, scaleTo int64, maxScale int64)
	RequestScale(ctx context.Context, scaledObject *kedav1alpha1.ScaledObject, isActive bool, isError bool, options *ScaleExecutorOptions)
}

ScaleExecutor contains methods RequestJobScale and RequestScale

func NewScaleExecutor

func NewScaleExecutor(client runtimeclient.Client, scaleClient scale.ScalesGetter, reconcilerScheme *runtime.Scheme, recorder record.EventRecorder) ScaleExecutor

NewScaleExecutor creates a ScaleExecutor object

type ScaleExecutorOptions

type ScaleExecutorOptions struct {
	ActiveTriggers []string
}

ScaleExecutorOptions contains the optional parameters for the RequestScale method.

type ScalingStrategy

type ScalingStrategy interface {
	GetEffectiveMaxScale(maxScale, runningJobCount, pendingJobCount, maxReplicaCount, scaleTo int64) (int64, int64)
}

ScalingStrategy is an interface for switching scaling algorithm

func NewScalingStrategy

func NewScalingStrategy(logger logr.Logger, scaledJob *kedav1alpha1.ScaledJob) ScalingStrategy

NewScalingStrategy returns ScalingStrategy instance