executor

Documentation

Index

• func GetPausedReplicaCount(scaledObject *kedav1alpha1.ScaledObject) (*int32, error)
• type ScaleExecutor
  • func NewScaleExecutor(client runtimeclient.Client, scaleClient scale.ScalesGetter, ...) ScaleExecutor
• 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, scaleTo int64, maxScale int64)
	RequestScale(ctx context.Context, scaledObject *kedav1alpha1.ScaledObject, isActive bool, isError bool)
}

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 ScalingStrategy

type ScalingStrategy interface {
	GetEffectiveMaxScale(maxScale, runningJobCount, pendingJobCount, maxReplicaCount 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