scaler

Jun 6, 2020

Changes in this version

type Scaler

+ func (s *Scaler) Start()

+ func (s *Scaler) String() string

Oct 13, 2019

Changes in this version

+ type Option func(c *Scaler)

+ func DryRunMode(enable bool) Option

+ func MaxOpenScalingTickets(num uint) Option

+ func WatcherInterval(interval time.Duration) Option

+ func WithLogger(logger zerolog.Logger) Option

type Scaler

+ func New(scalingTarget ScalingTarget, scalingObject ScalingObject, metrics Metrics, ...) (*Scaler, error)

+ func (s *Scaler) GetTimeOfLastScaleAction() time.Time

+ type ScalingObject struct

+ MaxCount uint

+ MinCount uint

+ Name string

Sep 24, 2019

Changes in this version

type Config

+ WatcherInterval time.Duration

type ScalingTarget

+ AdjustScalingObjectCount func(scalingObject string, min uint, max uint, from uint, to uint) error

+ String func() string

Sep 12, 2019

Changes in this version

+ type Config struct

+ Logger zerolog.Logger

+ MaxCount uint

+ MaxOpenScalingTickets uint

+ MinCount uint

+ Name string

+ func (cfg Config) New(scalingTarget ScalingTarget, metrics Metrics) (*Scaler, error)

+ type Metrics struct

+ func NewMetrics() Metrics

+ type Scaler struct

+ func (s *Scaler) GetCount() (uint, error)

+ func (s *Scaler) GetName() string

+ func (s *Scaler) Join()

+ func (s *Scaler) Run()

+ func (s *Scaler) ScaleTo(desiredCount uint, dryRun bool) error

+ func (s *Scaler) Stop()

+ type ScalingTarget interface

+ GetScalingObjectCount func(scalingObject string) (uint, error)

+ IsScalingObjectDead func(scalingObject string) (bool, error)

+ SetScalingObjectCount func(scalingObject string, count uint) error

+ type ScalingTicket struct

+ func NewScalingTicket(desiredCount uint, dryRun bool) ScalingTicket