autoscaler

Documentation

Index

• type Autoscaler
  • func New(queue qbas.Queue, rc *rc.ReplicationController, cfg qbas.Config, ...) Autoscaler
  • func (as Autoscaler) Backlog(ctx context.Context) (int64, error)
  • func (as Autoscaler) Resize(ctx context.Context, newSize int64) error
  • func (as Autoscaler) Run(ctx context.Context, refresh time.Duration)
  • func (as Autoscaler) ScaleDown(ctx context.Context, newSize int64) error
  • func (as Autoscaler) Size(ctx context.Context) (int64, error)

Types

type Autoscaler

type Autoscaler struct {
	// contains filtered or unexported fields
}

func New

func New(queue qbas.Queue, rc *rc.ReplicationController, cfg qbas.Config, logger *zap.Logger) Autoscaler

func (Autoscaler) Backlog

func (as Autoscaler) Backlog(ctx context.Context) (int64, error)

func (Autoscaler) Resize

func (as Autoscaler) Resize(ctx context.Context, newSize int64) error

func (Autoscaler) Run

func (as Autoscaler) Run(ctx context.Context, refresh time.Duration)

func (Autoscaler) ScaleDown

func (as Autoscaler) ScaleDown(ctx context.Context, newSize int64) error

func (Autoscaler) Size

func (as Autoscaler) Size(ctx context.Context) (int64, error)