Skip to content

Commit

Permalink
Update influxdb_scaler.go file. (#1388)
Browse files Browse the repository at this point in the history
Signed-off-by: Shubham82 <shubham.kuchhal@india.nec.com>
  • Loading branch information
Shubham82 authored Dec 1, 2020
1 parent 342136e commit d57dfdd
Showing 1 changed file with 8 additions and 6 deletions.
14 changes: 8 additions & 6 deletions pkg/scalers/influxdb_scaler.go
Original file line number Diff line number Diff line change
Expand Up @@ -57,15 +57,16 @@ func parseInfluxDBMetadata(config *ScalerConfig) (*influxDBMetadata, error) {
var serverURL string
var thresholdValue float64

if val, ok := config.TriggerMetadata["authToken"]; ok {
switch val, ok := config.TriggerMetadata["authToken"]; {
case ok:
authToken = val
} else if config.TriggerMetadata["authTokenFromEnv"] != "" {
case config.TriggerMetadata["authTokenFromEnv"] != "":
if val, ok := config.ResolvedEnv[config.TriggerMetadata["authTokenFromEnv"]]; ok {
authToken = val
} else {
return nil, fmt.Errorf("no auth token given")
}
} else {
default:
return nil, fmt.Errorf("no auth token given")
}

Expand All @@ -75,15 +76,16 @@ func parseInfluxDBMetadata(config *ScalerConfig) (*influxDBMetadata, error) {
metricName = strconv.FormatInt(time.Now().UTC().Unix(), 10)
}

if val, ok := config.TriggerMetadata["organizationName"]; ok {
switch val, ok := config.TriggerMetadata["organizationName"]; {
case ok:
organizationName = val
} else if config.TriggerMetadata["organizationNameFromEnv"] != "" {
case config.TriggerMetadata["organizationNameFromEnv"] != "":
if val, ok := config.ResolvedEnv[config.TriggerMetadata["organizationNameFromEnv"]]; ok {
organizationName = val
} else {
return nil, fmt.Errorf("no organization name given")
}
} else {
default:
return nil, fmt.Errorf("no organization name given")
}

Expand Down

0 comments on commit d57dfdd

Please sign in to comment.