@@ -216,32 +216,32 @@ func GetConsolidatedConfig(jsonRawConf json.RawMessage, env map[string]string, _
216
216
return result , nil
217
217
}
218
218
219
- func parseEnvs (env map [string ]string ) (Config , error ) {
220
- c := Config {
221
- Headers : make (map [string ]string ),
222
- }
219
+ func envBool (env map [string ]string , name string ) (null.Bool , error ) {
220
+ if v , vDefined := env [name ]; vDefined {
221
+ b , err := strconv .ParseBool (v )
222
+ if err != nil {
223
+ return null .NewBool (false , false ), err
224
+ }
223
225
224
- getEnvBool := func (env map [string ]string , name string ) (null.Bool , error ) {
225
- if v , vDefined := env [name ]; vDefined {
226
- b , err := strconv .ParseBool (v )
227
- if err != nil {
228
- return null .NewBool (false , false ), err
229
- }
226
+ return null .BoolFrom (b ), nil
227
+ }
228
+ return null .NewBool (false , false ), nil
229
+ }
230
230
231
- return null .BoolFrom (b ), nil
231
+ func envMap (env map [string ]string , prefix string ) map [string ]string {
232
+ result := make (map [string ]string )
233
+ for ek , ev := range env {
234
+ if strings .HasPrefix (ek , prefix ) {
235
+ k := strings .TrimPrefix (ek , prefix )
236
+ result [k ] = ev
232
237
}
233
- return null .NewBool (false , false ), nil
234
238
}
239
+ return result
240
+ }
235
241
236
- getEnvMap := func (env map [string ]string , prefix string ) map [string ]string {
237
- result := make (map [string ]string )
238
- for ek , ev := range env {
239
- if strings .HasPrefix (ek , prefix ) {
240
- k := strings .TrimPrefix (ek , prefix )
241
- result [k ] = ev
242
- }
243
- }
244
- return result
242
+ func parseEnvs (env map [string ]string ) (Config , error ) {
243
+ c := Config {
244
+ Headers : make (map [string ]string ),
245
245
}
246
246
247
247
if pushInterval , pushIntervalDefined := env ["K6_PROMETHEUS_RW_PUSH_INTERVAL" ]; pushIntervalDefined {
@@ -254,7 +254,7 @@ func parseEnvs(env map[string]string) (Config, error) {
254
254
c .ServerURL = null .StringFrom (url )
255
255
}
256
256
257
- if b , err := getEnvBool (env , "K6_PROMETHEUS_RW_INSECURE_SKIP_TLS_VERIFY" ); err != nil {
257
+ if b , err := envBool (env , "K6_PROMETHEUS_RW_INSECURE_SKIP_TLS_VERIFY" ); err != nil {
258
258
return c , err
259
259
} else if b .Valid {
260
260
c .InsecureSkipTLSVerify = b
@@ -276,7 +276,7 @@ func parseEnvs(env map[string]string) (Config, error) {
276
276
c .ClientCertificateKey = null .StringFrom (clientCertificateKey )
277
277
}
278
278
279
- envHeaders := getEnvMap (env , "K6_PROMETHEUS_RW_HEADERS_" )
279
+ envHeaders := envMap (env , "K6_PROMETHEUS_RW_HEADERS_" )
280
280
for k , v := range envHeaders {
281
281
c .Headers [k ] = v
282
282
}
@@ -291,13 +291,13 @@ func parseEnvs(env map[string]string) (Config, error) {
291
291
}
292
292
}
293
293
294
- if b , err := getEnvBool (env , "K6_PROMETHEUS_RW_TREND_AS_NATIVE_HISTOGRAM" ); err != nil {
294
+ if b , err := envBool (env , "K6_PROMETHEUS_RW_TREND_AS_NATIVE_HISTOGRAM" ); err != nil {
295
295
return c , err
296
296
} else if b .Valid {
297
297
c .TrendAsNativeHistogram = b
298
298
}
299
299
300
- if b , err := getEnvBool (env , "K6_PROMETHEUS_RW_STALE_MARKERS" ); err != nil {
300
+ if b , err := envBool (env , "K6_PROMETHEUS_RW_STALE_MARKERS" ); err != nil {
301
301
return c , err
302
302
} else if b .Valid {
303
303
c .StaleMarkers = b
0 commit comments