scaler

Documentation

Index

• Constants
• func CurrentQueueSize(sess *session.Session, queueUrl string) (int64, error)
• type Scaler
  • func New(client *kubernetes.Clientset, store cache.Store, interval time.Duration) *Scaler
  • func (s Scaler) Run(ctx context.Context) error

Constants

const (
	ReasonScaleDeployment       = "ScaleSuccess"
	ReasonFailedScaleDeployment = "ScaleFail"
)

Functions

func CurrentQueueSize

func CurrentQueueSize(sess *session.Session, queueUrl string) (int64, error)

Types

type Scaler

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

func New

func New(client *kubernetes.Clientset, store cache.Store, interval time.Duration) *Scaler

func (Scaler) Run

func (s Scaler) Run(ctx context.Context) error