autoscale

Documentation

Index

• Constants
• func DeleteRule(metadataFilter string) error
• func Initialize() error
• func RunOnce(w io.Writer) error
• type Config
  • func CurrentConfig() (*Config, error)
  • func (a *Config) Shutdown(ctx context.Context) error
  • func (a *Config) String() string
• type Event
  • func ListAutoScaleEvents(skip, limit int) ([]Event, error)
• type EventCustomData
• type Rule
  • func AutoScaleRuleForMetadata(metadataFilter string) (*Rule, error)
  • func ListRules() ([]Rule, error)
  • func (r *Rule) Update() error
• type ScalerResult
  • func (r *ScalerResult) IsRebalanceOnly() bool
  • func (r *ScalerResult) NoAction() bool

Constants

const (
	EventKind = "autoscale"
)

Functions

func DeleteRule

func DeleteRule(metadataFilter string) error

func Initialize

func Initialize() error

func RunOnce

func RunOnce(w io.Writer) error

Types

type Config

type Config struct {
	WaitTimeNewMachine  time.Duration
	RunInterval         time.Duration
	TotalMemoryMetadata string

	Enabled bool
	// contains filtered or unexported fields
}

func CurrentConfig

func CurrentConfig() (*Config, error)

func (*Config) Shutdown

func (a *Config) Shutdown(ctx context.Context) error

func (*Config) String

func (a *Config) String() string

type Event

type Event struct {
	ID            interface{} `bson:"_id"`
	MetadataValue string
	Action        string // scaleActionAdd, scaleActionRemove, scaleActionRebalance
	Reason        string // dependend on scaler
	StartTime     time.Time
	EndTime       time.Time `bson:",omitempty"`
	Successful    bool
	Error         string             `bson:",omitempty"`
	Node          provision.NodeSpec `bson:",omitempty"`
	Log           string             `bson:",omitempty"`
	Nodes         []provision.NodeSpec
}

func ListAutoScaleEvents

func ListAutoScaleEvents(skip, limit int) ([]Event, error)

type EventCustomData

type EventCustomData struct {
	Result *ScalerResult
	Nodes  []provision.NodeSpec
	Rule   *Rule
}

type Rule

type Rule struct {
	MetadataFilter    string `bson:"_id"`
	Error             string `bson:"-"`
	MaxContainerCount int
	ScaleDownRatio    float32
	MaxMemoryRatio    float32
	Enabled           bool
	PreventRebalance  bool
}

func AutoScaleRuleForMetadata

func AutoScaleRuleForMetadata(metadataFilter string) (*Rule, error)

func ListRules

func ListRules() ([]Rule, error)

func (*Rule) Update

func (r *Rule) Update() error

type ScalerResult

type ScalerResult struct {
	ToAdd       int
	ToRemove    []provision.NodeSpec
	ToRebalance bool
	Reason      string
}

func (*ScalerResult) IsRebalanceOnly

func (r *ScalerResult) IsRebalanceOnly() bool

func (*ScalerResult) NoAction

func (r *ScalerResult) NoAction() bool