autoscaler

Documentation

Index

• type AsyncScaler
  • func NewAsyncScaler(k8sClient *k8s.Client, promClient promv1.API) *AsyncScaler
  • func (s *AsyncScaler) CurrentRequestedReplicas(apiName string) (int32, error)
  • func (s *AsyncScaler) GetAutoscalingSpec(apiName string) (*userconfig.Autoscaling, error)
  • func (s *AsyncScaler) GetInFlightRequests(apiName string, window time.Duration) (*float64, error)
  • func (s *AsyncScaler) Scale(apiName string, request int32) error
• type Autoscaler
  • func New(logger *zap.SugaredLogger) *Autoscaler
  • func (a *Autoscaler) AddAPI(api userconfig.Resource) error
  • func (a *Autoscaler) AddScaler(scaler Scaler, kind userconfig.Kind)
  • func (a *Autoscaler) Awaken(api userconfig.Resource) error
  • func (a *Autoscaler) RemoveAPI(api userconfig.Resource)
  • func (a *Autoscaler) Stop()
• type Client
  • func NewClient(endpoint string) Client
• type Handler
  • func NewHandler(autoscaler *Autoscaler) *Handler
  • func (h *Handler) Awaken(w http.ResponseWriter, r *http.Request)
• type RealtimeScaler
  • func NewRealtimeScaler(k8sClient *k8s.Client, promClient promv1.API, logger *zap.SugaredLogger) *RealtimeScaler
  • func (s *RealtimeScaler) CurrentRequestedReplicas(apiName string) (int32, error)
  • func (s *RealtimeScaler) GetAutoscalingSpec(apiName string) (*userconfig.Autoscaling, error)
  • func (s *RealtimeScaler) GetInFlightRequests(apiName string, window time.Duration) (*float64, error)
  • func (s *RealtimeScaler) Scale(apiName string, request int32) error
• type Scaler
• type ScalerFunc
  • func (s *ScalerFunc) CurrentRequestedReplicas(apiName string) (int32, error)
  • func (s *ScalerFunc) GetAutoscalingSpec(apiName string) (*userconfig.Autoscaling, error)
  • func (s *ScalerFunc) GetInFlightRequests(apiName string, window time.Duration) (*float64, error)
  • func (s *ScalerFunc) Scale(apiName string, request int32) error

Types

type AsyncScaler

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

func NewAsyncScaler

func NewAsyncScaler(k8sClient *k8s.Client, promClient promv1.API) *AsyncScaler

func (*AsyncScaler) CurrentRequestedReplicas

func (s *AsyncScaler) CurrentRequestedReplicas(apiName string) (int32, error)

func (*AsyncScaler) GetAutoscalingSpec

func (s *AsyncScaler) GetAutoscalingSpec(apiName string) (*userconfig.Autoscaling, error)

func (*AsyncScaler) GetInFlightRequests

func (s *AsyncScaler) GetInFlightRequests(apiName string, window time.Duration) (*float64, error)

func (*AsyncScaler) Scale

func (s *AsyncScaler) Scale(apiName string, request int32) error

type Autoscaler

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

func New

func New(logger *zap.SugaredLogger) *Autoscaler

func (*Autoscaler) AddAPI

func (a *Autoscaler) AddAPI(api userconfig.Resource) error

func (*Autoscaler) AddScaler

func (a *Autoscaler) AddScaler(scaler Scaler, kind userconfig.Kind)

func (*Autoscaler) Awaken

func (a *Autoscaler) Awaken(api userconfig.Resource) error

func (*Autoscaler) RemoveAPI

func (a *Autoscaler) RemoveAPI(api userconfig.Resource)

func (*Autoscaler) Stop

func (a *Autoscaler) Stop()

type Client

type Client interface {
	Awaken(api userconfig.Resource) error
}

func NewClient

func NewClient(endpoint string) Client

type Handler

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

func NewHandler

func NewHandler(autoscaler *Autoscaler) *Handler

func (*Handler) Awaken

func (h *Handler) Awaken(w http.ResponseWriter, r *http.Request)

type RealtimeScaler

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

func NewRealtimeScaler

func NewRealtimeScaler(k8sClient *k8s.Client, promClient promv1.API, logger *zap.SugaredLogger) *RealtimeScaler

func (*RealtimeScaler) CurrentRequestedReplicas

func (s *RealtimeScaler) CurrentRequestedReplicas(apiName string) (int32, error)

func (*RealtimeScaler) GetAutoscalingSpec

func (s *RealtimeScaler) GetAutoscalingSpec(apiName string) (*userconfig.Autoscaling, error)

func (*RealtimeScaler) GetInFlightRequests

func (s *RealtimeScaler) GetInFlightRequests(apiName string, window time.Duration) (*float64, error)

func (*RealtimeScaler) Scale

func (s *RealtimeScaler) Scale(apiName string, request int32) error

type Scaler

type Scaler interface {
	Scale(apiName string, request int32) error
	GetInFlightRequests(apiName string, window time.Duration) (*float64, error)
	GetAutoscalingSpec(apiName string) (*userconfig.Autoscaling, error)
	CurrentRequestedReplicas(apiName string) (int32, error)
}

type ScalerFunc

type ScalerFunc struct {
	ScaleFunc                    func(apiName string, request int32) error
	GetInFlightRequestsFunc      func(apiName string, window time.Duration) (*float64, error)
	GetAutoscalingSpecFunc       func(apiName string) (*userconfig.Autoscaling, error)
	CurrentRequestedReplicasFunc func(apiName string) (int32, error)
}

func (*ScalerFunc) CurrentRequestedReplicas

func (s *ScalerFunc) CurrentRequestedReplicas(apiName string) (int32, error)

func (*ScalerFunc) GetAutoscalingSpec

func (s *ScalerFunc) GetAutoscalingSpec(apiName string) (*userconfig.Autoscaling, error)

func (*ScalerFunc) GetInFlightRequests

func (s *ScalerFunc) GetInFlightRequests(apiName string, window time.Duration) (*float64, error)

func (*ScalerFunc) Scale

func (s *ScalerFunc) Scale(apiName string, request int32) error