scheduler

Documentation

Index

• func RunBasicScaler(environmentID string, providers []*resource.ResourceProvider, ...) (*models.ScalerRunInfo, error)
• type EnvironmentScaler
• type L0EnvironmentScaler
  • func NewL0EnvironmentScaler(c resource.ConsumerGetter, p resource.ProviderManager) *L0EnvironmentScaler
  • func (r *L0EnvironmentScaler) Scale(environmentID string) (*models.ScalerRunInfo, error)
  • func (r *L0EnvironmentScaler) ScheduleRun(environmentID string, delay time.Duration)

Functions

func RunBasicScaler

func RunBasicScaler(
	environmentID string,
	providers []*resource.ResourceProvider,
	consumers []resource.ResourceConsumer,
	providerManager resource.ProviderManager,
) (*models.ScalerRunInfo, error)

Types

type EnvironmentScaler

type EnvironmentScaler interface {
	Scale(environmentID string) (*models.ScalerRunInfo, error)
	ScheduleRun(environmentID string, delay time.Duration)
}

type L0EnvironmentScaler

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

func NewL0EnvironmentScaler

func NewL0EnvironmentScaler(c resource.ConsumerGetter, p resource.ProviderManager) *L0EnvironmentScaler

func (*L0EnvironmentScaler) Scale

func (r *L0EnvironmentScaler) Scale(environmentID string) (*models.ScalerRunInfo, error)

func (*L0EnvironmentScaler) ScheduleRun

func (r *L0EnvironmentScaler) ScheduleRun(environmentID string, delay time.Duration)