scaling

Apr 14, 2020

Changes in this version

+ const MinActivators

type DeciderSpec

+ ActivatorCapacity float64

type DeciderStatus

+ NumActivators int32

Mar 3, 2020

Changes in this version

+ type Autoscaler struct

+ func New(namespace string, revision string, metricClient metrics.MetricClient, ...) (*Autoscaler, error)

+ func (a *Autoscaler) Scale(ctx context.Context, now time.Time) (desiredPodCount int32, excessBC int32, validScale bool)

+ func (a *Autoscaler) Update(deciderSpec *DeciderSpec) error

+ type Decider struct

+ Spec DeciderSpec

+ Status DeciderStatus

+ func (in *Decider) DeepCopy() *Decider

+ func (in *Decider) DeepCopyInto(out *Decider)

+ type DeciderSpec struct

+ MaxScaleDownRate float64

+ MaxScaleUpRate float64

+ PanicThreshold float64

+ ScalingMetric string

+ ServiceName string

+ StableWindow time.Duration

+ TargetBurstCapacity float64

+ TargetValue float64

+ TickInterval time.Duration

+ TotalValue float64

+ type DeciderStatus struct

+ DesiredScale int32

+ ExcessBurstCapacity int32

+ type MultiScaler struct

+ func NewMultiScaler(stopCh <-chan struct{}, uniScalerFactory UniScalerFactory, ...) *MultiScaler

+ func (m *MultiScaler) Create(ctx context.Context, decider *Decider) (*Decider, error)

+ func (m *MultiScaler) Delete(ctx context.Context, namespace, name string) error

+ func (m *MultiScaler) Get(ctx context.Context, namespace, name string) (*Decider, error)

+ func (m *MultiScaler) Inform(event types.NamespacedName) bool

+ func (m *MultiScaler) Poke(key types.NamespacedName, stat metrics.Stat)

+ func (m *MultiScaler) Update(ctx context.Context, decider *Decider) (*Decider, error)

+ func (m *MultiScaler) Watch(fn func(types.NamespacedName))

+ type UniScaler interface

+ Scale func(context.Context, time.Time) (int32, int32, bool)

+ Update func(*DeciderSpec) error

+ type UniScalerFactory func(*Decider) (UniScaler, error)