scaler

package

v0.0.0-...-260b785 Latest Latest Go to latest Published: Jan 28, 2024 License: Apache-2.0 Imports: 14 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

This section is empty.

This section is empty.

This section is empty.

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

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

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

New creates an instance of the scaler object

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

GetMetricSpec defines the average target value for the metric

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

GetMetrics returns the total value for the metric

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 (s *Scaler) ScaleUp(ctx context.Context, project, service, version string) error

ScaleUp instructs keda to scale the service from 0 to 1

func (s *Scaler) Start()

Start begins the grpc server

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.

Path	Synopsis
externalscaler