feat: Support keda-add-on configs (#243)

* feat: Support keda-add-on configs

Signed-off-by: Jorge Turrado <jorge_turrado@hotmail.es>

* .

Signed-off-by: Jorge Turrado <jorge_turrado@hotmail.es>

---------

Signed-off-by: Jorge Turrado <jorge_turrado@hotmail.es>

Author: JorTurFer

e2e/images/external-scaler/externalscaler/externalscaler.pb.go

@@ -1,7 +1,7 @@
 syntax = "proto3";
 
 package externalscaler;
-option go_package = "github.com/kedacore/test-tools/external-scaler-e2e/externalscaler";
+option go_package = ".;externalscaler";
 
 service ExternalScaler {
     rpc IsActive(ScaledObjectRef) returns (IsActiveResponse) {}
@@ -30,6 +30,7 @@ message MetricSpec {
     // deprecated, use targetSizeFloat instead
     int64 targetSize = 2;
     double targetSizeFloat = 3;
+    optional string metricType = 4;
 }
 
 message GetMetricsRequest {

e2e/images/external-scaler/externalscaler/externalscaler.proto

@@ -15,8 +15,21 @@ import (
 	pb "github.com/kedacore/test-tools/external-scaler/externalscaler"
 )
 
-func setValue(w http.ResponseWriter, r *http.Request) {
+func setType(w http.ResponseWriter, r *http.Request) {
+	vars := mux.Vars(r)
+	metricType := vars["type"]
+	log.Printf("new metric type: %s\n", metricType)
+	if metricType != "AverageValue" && metricType != "Value" && metricType != "null" {
+		log.Print("invalid type -> it won't be included in GetMetricSpecResponse")
+		return
+	}
+	ExternalScalerType = nil
+	if metricType != "null" {
+		ExternalScalerType = &metricType
+	}
+}
 
+func setValue(w http.ResponseWriter, r *http.Request) {
 	vars := mux.Vars(r)
 	number := vars["number"]
 	ExternalScalerValue, _ = strconv.ParseInt(number, 10, 64)
@@ -38,20 +51,22 @@ func setFloatValue(w http.ResponseWriter, r *http.Request) {
 
 func RunManagementApi() {
 	r := mux.NewRouter()
+	r.HandleFunc("/api/type/{type}", setType).Methods("POST")
 	r.HandleFunc("/api/value/{number:[-0-9]+}", setValue).Methods("POST")
 	r.HandleFunc("/api/floatvalue/{number:[-\\.0-9]+}", setFloatValue).Methods("POST")
 	r.HandleFunc("/ready", func(w http.ResponseWriter, r *http.Request) {
 		w.WriteHeader(http.StatusOK)
 	}).Methods("GET")
 	http.Handle("/", r)
 	fmt.Printf("Running http management server on port: %d\n", 8080)
-	fmt.Print("example usage:\n - POST -> localhost:8080/api/value/3\n - POST -> localhost:8080/api/floatvalue/3.14\n")
+	fmt.Print("example usage:\n - POST -> localhost:8080/api/value/3\n - POST -> localhost:8080/api/floatvalue/3.14\n - POST -> localhost:8080/api/type/AverageValue\n")
 	fmt.Print("if you set one of those values as negative, it won't be sent in the payload\n")
 	http.ListenAndServe(":8080", nil)
 }
 
 var ExternalScalerValue int64 = 0
 var ExternalScalerValueFloat = .0
+var ExternalScalerType *string = nil
 
 type ExternalScaler struct {
 	pb.UnimplementedExternalScalerServer
@@ -72,10 +87,9 @@ func (es *ExternalScaler) GetMetricSpec(ctx context.Context, scaledObjectRef *pb
 	if err != nil {
 		return nil, fmt.Errorf("invalid value for metric threshold - %s", err)
 	}
-
 	return &pb.GetMetricSpecResponse{
 		MetricSpecs: []*pb.MetricSpec{
-			{MetricName: "external-scaler-e2e-test", TargetSizeFloat: metricThreshold},
+			{MetricName: "external-scaler-e2e-test", TargetSizeFloat: metricThreshold, MetricType: ExternalScalerType},
 		},
 	}, nil
 }