add constants

Signed-off-by: Manuel Cañete <mcaneteubeda@gmail.com>
kedacore · Nov 5, 2022 · 339686e · 339686e
1 parent 1f2764f
commit 339686e
Show file tree

Hide file tree

Showing 2 changed files with 12 additions and 9 deletions.
diff --git a/pkg/scalers/nats_jetstream_scaler.go b/pkg/scalers/nats_jetstream_scaler.go
@@ -19,9 +19,10 @@ import (
 )
 
 const (
-	jetStreamMetricType                   = "External"
-	defaultJetStreamLagThreshold          = 10
-	defaultNatsMonitoringEndpointProtocol = "http"
+	jetStreamMetricType          = "External"
+	defaultJetStreamLagThreshold = 10
+	natsHttpProtocol             = "http"
+	natsHttpsProtocol            = "https"
 )
 
 type natsJetStreamScaler struct {
@@ -164,9 +165,9 @@ func parseNATSJetStreamMetadata(config *ScalerConfig) (natsJetStreamMetadata, er
 }
 
 func (s *natsJetStreamScaler) getNATSJetStreamEndpoint() string {
-	protocol := "http"
+	protocol := natsHttpProtocol
 	if s.metadata.useHttps {
-		protocol = "https"
+		protocol = natsHttpsProtocol
 	}
 	return fmt.Sprintf("%s://%s/jsz?acc=%s&consumers=true&config=true", protocol, s.metadata.monitoringEndpoint, s.metadata.account)
 }

diff --git a/pkg/scalers/stan_scaler.go b/pkg/scalers/stan_scaler.go
@@ -56,8 +56,10 @@ type stanMetadata struct {
 }
 
 const (
-	stanMetricType          = "External"
-	defaultStanLagThreshold = 10
+	stanMetricType             = "External"
+	defaultStanLagThreshold    = 10
+	natsStreamingHttpProtocol  = "http"
+	natsStreamingHttpsProtocol = "https"
 )
 
 // NewStanScaler creates a new stanScaler
@@ -179,9 +181,9 @@ func (s *stanScaler) IsActive(ctx context.Context) (bool, error) {
 }
 
 func (s *stanScaler) getSTANChannelsEndpoint() string {
-	protocol := "http"
+	protocol := natsStreamingHttpProtocol
 	if s.metadata.useHttps {
-		protocol = "https"
+		protocol = natsStreamingHttpsProtocol
 	}
 	return fmt.Sprintf("%s://%s/streaming/channelsz", protocol, s.metadata.natsServerMonitoringEndpoint)
 }