scaler

Documentation

Index

• func RetrieveFromParameterStore(sess *session.Session, key string) (string, error)
• type ASGDriver
  • func (a *ASGDriver) Describe() (AutoscaleGroupDetails, error)
  • func (a *ASGDriver) GetAutoscalingActivities(ctx context.Context, nextToken *string) (*autoscaling.DescribeScalingActivitiesOutput, error)
  • func (a *ASGDriver) GetLastScalingInAndOutActivity(ctx context.Context, findScaleOut, findScaleIn bool) (*autoscaling.Activity, *autoscaling.Activity, error)
  • func (a *ASGDriver) SetDesiredCapacity(count int64) error
• type AutoscaleGroupDetails
• type Params
• type ScaleParams
• type Scaler
  • func NewScaler(client *buildkite.Client, sess *session.Session, params Params) (*Scaler, error)
  • func (s *Scaler) LastScaleIn() time.Time
  • func (s *Scaler) LastScaleOut() time.Time
  • func (s *Scaler) Run() (time.Duration, error)
• type ScalingCalculator
  • func (sc *ScalingCalculator) DesiredCount(metrics *buildkite.AgentMetrics, asg *AutoscaleGroupDetails) int64

Functions

func RetrieveFromParameterStore

func RetrieveFromParameterStore(sess *session.Session, key string) (string, error)

Types

type ASGDriver

type ASGDriver struct {
	Name                              string
	Sess                              *session.Session
	MaxDescribeScalingActivitiesPages int
}

func (*ASGDriver) Describe

func (a *ASGDriver) Describe() (AutoscaleGroupDetails, error)

func (*ASGDriver) GetAutoscalingActivities

func (a *ASGDriver) GetAutoscalingActivities(ctx context.Context, nextToken *string) (*autoscaling.DescribeScalingActivitiesOutput, error)

func (*ASGDriver) GetLastScalingInAndOutActivity

func (a *ASGDriver) GetLastScalingInAndOutActivity(ctx context.Context, findScaleOut, findScaleIn bool) (*autoscaling.Activity, *autoscaling.Activity, error)

func (*ASGDriver) SetDesiredCapacity

func (a *ASGDriver) SetDesiredCapacity(count int64) error

type AutoscaleGroupDetails

type AutoscaleGroupDetails struct {
	Pending      int64
	DesiredCount int64
	MinSize      int64
	MaxSize      int64
}

type Params

type Params struct {
	AutoScalingGroupName     string
	AgentsPerInstance        int
	BuildkiteAgentToken      string
	BuildkiteQueue           string
	UserAgent                string
	PublishCloudWatchMetrics bool
	DryRun                   bool
	IncludeWaiting           bool
	ScaleInParams            ScaleParams
	ScaleOutParams           ScaleParams
	InstanceBuffer           int
	ScaleOnlyAfterAllEvent   bool
}

type ScaleParams

type ScaleParams struct {
	Disable        bool
	CooldownPeriod time.Duration
	Factor         float64
	LastEvent      time.Time
}

type Scaler

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

func NewScaler

func NewScaler(client *buildkite.Client, sess *session.Session, params Params) (*Scaler, error)

func (*Scaler) LastScaleIn

func (s *Scaler) LastScaleIn() time.Time

func (*Scaler) LastScaleOut

func (s *Scaler) LastScaleOut() time.Time

func (*Scaler) Run

func (s *Scaler) Run() (time.Duration, error)

type ScalingCalculator

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

func (*ScalingCalculator) DesiredCount

func (sc *ScalingCalculator) DesiredCount(metrics *buildkite.AgentMetrics, asg *AutoscaleGroupDetails) int64