qbas

Documentation

Index

• type Config
• type InstanceManager
• type Operation
  • func Autoscale(ctx context.Context, cfg Config, qbim QueueBasedInstanceManager) (Operation, error)
• type Queue
• type QueueBasedInstanceManager

Types

type Config

type Config struct {
	Ratio        float64 `json:"ratio"`
	MinRatio     float64 `json:"minRatio"`
	MaxStep      int64   `json:"maxStep"`
	MaxInstances int64   `json:"maxInstances"`
	MinInstances int64   `json:"minInstances"`
}

type InstanceManager

type InstanceManager interface {
	Size(ctx context.Context) (int64, error)
	Resize(ctx context.Context, newSize int64) error
	ScaleDown(ctx context.Context, newSize int64) error
}

type Operation

type Operation struct {
	Backlog   int64 `json:"backlog"`
	Instances int64 `json:"instances"`
	Delta     int64 `json:"delta"`
}

func Autoscale

func Autoscale(ctx context.Context, cfg Config, qbim QueueBasedInstanceManager) (Operation, error)

type Queue

type Queue interface {
	Backlog(ctx context.Context) (int64, error)
}

type QueueBasedInstanceManager

type QueueBasedInstanceManager interface {
	Queue
	InstanceManager
}