scalingengine

Documentation

Index

• type ActiveScheduleNotFoundError
  • func (ase *ActiveScheduleNotFoundError) Error() string
• type AppNotFoundError
• type ScalingEngine
  • func NewScalingEngine(logger lager.Logger, cfClient cf.CFClient, policyDB db.PolicyDB, ...) ScalingEngine
• type StripedLock
  • func NewStripedLock(capacity int) *StripedLock
  • func (sl *StripedLock) GetLock(key string) *sync.Mutex

Types

type ActiveScheduleNotFoundError

type ActiveScheduleNotFoundError struct {
}

func (*ActiveScheduleNotFoundError) Error

func (ase *ActiveScheduleNotFoundError) Error() string

type AppNotFoundError

type AppNotFoundError struct {
}

type ScalingEngine

type ScalingEngine interface {
	Scale(appId string, trigger *models.Trigger) (*models.AppScalingResult, error)
	ComputeNewInstances(currentInstances int, adjustment string) (int, error)
	SetActiveSchedule(appId string, schedule *models.ActiveSchedule) error
	RemoveActiveSchedule(appId string, scheduleId string) error
}

func NewScalingEngine

func NewScalingEngine(logger lager.Logger, cfClient cf.CFClient, policyDB db.PolicyDB, scalingEngineDB db.ScalingEngineDB, clock clock.Clock, defaultCoolDownSecs int, lockSize int) ScalingEngine

type StripedLock

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

func NewStripedLock

func NewStripedLock(capacity int) *StripedLock

func (*StripedLock) GetLock

func (sl *StripedLock) GetLock(key string) *sync.Mutex