scaler

Documentation

Index

• type Scaler
  • func New(prometheusAddr string) (*Scaler, error)
  • func (s *Scaler) GetMetricSpec(ctx context.Context, scaledObject *pb.ScaledObjectRef) (*pb.GetMetricSpecResponse, error)
  • func (s *Scaler) GetMetrics(ctx context.Context, metricRequest *pb.GetMetricsRequest) (*pb.GetMetricsResponse, error)
  • func (s *Scaler) IsActive(ctx context.Context, scaledObject *pb.ScaledObjectRef) (*pb.IsActiveResponse, error)
  • func (s *Scaler) ScaleUp(ctx context.Context, project, service, version string) error
  • func (s *Scaler) Start()
  • func (s *Scaler) StreamIsActive(scaledObject *pb.ScaledObjectRef, ...) error

Types

type Scaler

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

Scaler is responsible to implement an external-push scaler for keda

func New

func New(prometheusAddr string) (*Scaler, error)

New creates an instance of the scaler object

func (*Scaler) GetMetricSpec

func (s *Scaler) GetMetricSpec(ctx context.Context, scaledObject *pb.ScaledObjectRef) (*pb.GetMetricSpecResponse, error)

GetMetricSpec defines the average target value for the metric

func (*Scaler) GetMetrics

func (s *Scaler) GetMetrics(ctx context.Context, metricRequest *pb.GetMetricsRequest) (*pb.GetMetricsResponse, error)

GetMetrics returns the total value for the metric

func (*Scaler) IsActive

func (s *Scaler) IsActive(ctx context.Context, scaledObject *pb.ScaledObjectRef) (*pb.IsActiveResponse, error)

IsActive is called by the keda controller to check if keda should scale the deployment from 0 to 1

func (*Scaler) ScaleUp

func (s *Scaler) ScaleUp(ctx context.Context, project, service, version string) error

ScaleUp instructs keda to scale the service from 0 to 1

func (*Scaler) Start

func (s *Scaler) Start()

Start begins the grpc server

func (*Scaler) StreamIsActive

func (s *Scaler) StreamIsActive(scaledObject *pb.ScaledObjectRef, epsServer pb.ExternalScaler_StreamIsActiveServer) error

StreamIsActive is called by keda controller once to allow us to stream isActive events to it.