Skip to content
This repository was archived by the owner on Mar 18, 2025. It is now read-only.

Commit bcf82f6

Browse files
authored
Merge pull request #70 from grafana/drop-cli-config
Drop options from cli argument
2 parents b34f0b1 + e5aa4e6 commit bcf82f6

File tree

2 files changed

+25
-22
lines changed

2 files changed

+25
-22
lines changed

pkg/remotewrite/config.go

Lines changed: 10 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -141,13 +141,16 @@ func GetConsolidatedConfig(jsonRawConf json.RawMessage, env map[string]string, u
141141
result = result.Apply(envConf)
142142
}
143143

144-
if url != "" {
145-
urlConf, err := parseArg(url)
146-
if err != nil {
147-
return result, fmt.Errorf("parse argument string options failed: %w", err)
148-
}
149-
result = result.Apply(urlConf)
150-
}
144+
// TODO: define a way for defining Output's options
145+
// then support them.
146+
//
147+
//if url != "" {
148+
//urlConf, err := parseArg(url)
149+
//if err != nil {
150+
//return result, fmt.Errorf("parse argument string options failed: %w", err)
151+
//}
152+
//result = result.Apply(urlConf)
153+
//}
151154

152155
return result, nil
153156
}

pkg/remotewrite/config_test.go

Lines changed: 15 additions & 15 deletions
Original file line numberDiff line numberDiff line change
@@ -120,13 +120,13 @@ func TestGetConsolidatedConfig(t *testing.T) {
120120
jsonRaw: json.RawMessage(fmt.Sprintf(`{"url":"%s"}`, u.String())),
121121
env: map[string]string{
122122
"K6_PROMETHEUS_INSECURE_SKIP_TLS_VERIFY": "false",
123-
"K6_PROMETHEUS_USER": "u",
123+
"K6_PROMETHEUS_USERNAME": "u",
124124
},
125-
arg: "username=user",
125+
// arg: "username=user",
126126
config: Config{
127127
URL: null.StringFrom(u.String()),
128128
InsecureSkipTLSVerify: null.BoolFrom(false),
129-
Username: null.NewString("user", true),
129+
Username: null.NewString("u", true),
130130
Password: null.NewString("", false),
131131
PushInterval: types.NullDurationFrom(defaultPushInterval),
132132
Headers: make(map[string]string),
@@ -138,12 +138,12 @@ func TestGetConsolidatedConfig(t *testing.T) {
138138
"K6_PROMETHEUS_USERNAME": "env",
139139
"K6_PROMETHEUS_PASSWORD": "env",
140140
},
141-
arg: "password=arg",
141+
// arg: "password=arg",
142142
config: Config{
143143
URL: null.StringFrom("http://json:9090"),
144144
InsecureSkipTLSVerify: null.BoolFrom(true),
145145
Username: null.StringFrom("env"),
146-
Password: null.StringFrom("arg"),
146+
Password: null.StringFrom("env"),
147147
PushInterval: types.NullDurationFrom(defaultPushInterval),
148148
Headers: make(map[string]string),
149149
},
@@ -156,10 +156,10 @@ func TestGetConsolidatedConfig(t *testing.T) {
156156
env: map[string]string{"K6_PROMETHEUS_INSECURE_SKIP_TLS_VERIFY": "d"},
157157
errString: "parse environment variables options failed",
158158
},
159-
"InvalidArg": {
160-
arg: "insecureSkipTLSVerify=wrongtime",
161-
errString: "parse argument string options failed",
162-
},
159+
//"InvalidArg": {
160+
//arg: "insecureSkipTLSVerify=wrongtime",
161+
//errString: "parse argument string options failed",
162+
//},
163163
}
164164

165165
for name, testCase := range testCases {
@@ -204,7 +204,7 @@ func TestOptionURL(t *testing.T) {
204204
}{
205205
"JSON": {jsonRaw: json.RawMessage(`{"url":"http://prometheus:9090/api/v1/write"}`)},
206206
"Env": {env: map[string]string{"K6_PROMETHEUS_REMOTE_URL": "http://prometheus:9090/api/v1/write"}},
207-
"Arg": {arg: "url=http://prometheus:9090/api/v1/write"},
207+
//"Arg": {arg: "url=http://prometheus:9090/api/v1/write"},
208208
}
209209

210210
expconfig := Config{
@@ -237,7 +237,7 @@ func TestOptionHeaders(t *testing.T) {
237237
}{
238238
"JSON": {jsonRaw: json.RawMessage(`{"headers":{"X-MY-HEADER1":"hval1","X-MY-HEADER2":"hval2"}}`)},
239239
"Env": {env: map[string]string{"K6_PROMETHEUS_HEADERS_X-MY-HEADER1": "hval1", "K6_PROMETHEUS_HEADERS_X-MY-HEADER2": "hval2"}},
240-
"Arg": {arg: "headers.X-MY-HEADER1=hval1,headers.X-MY-HEADER2=hval2"},
240+
//"Arg": {arg: "headers.X-MY-HEADER1=hval1,headers.X-MY-HEADER2=hval2"},
241241
}
242242

243243
expconfig := Config{
@@ -270,7 +270,7 @@ func TestOptionInsecureSkipTLSVerify(t *testing.T) {
270270
}{
271271
"JSON": {jsonRaw: json.RawMessage(`{"insecureSkipTLSVerify":false}`)},
272272
"Env": {env: map[string]string{"K6_PROMETHEUS_INSECURE_SKIP_TLS_VERIFY": "false"}},
273-
"Arg": {arg: "insecureSkipTLSVerify=false"},
273+
//"Arg": {arg: "insecureSkipTLSVerify=false"},
274274
}
275275

276276
expconfig := Config{
@@ -300,7 +300,7 @@ func TestOptionBasicAuth(t *testing.T) {
300300
}{
301301
"JSON": {jsonRaw: json.RawMessage(`{"username":"user1","password":"pass1"}`)},
302302
"Env": {env: map[string]string{"K6_PROMETHEUS_USERNAME": "user1", "K6_PROMETHEUS_PASSWORD": "pass1"}},
303-
"Arg": {arg: "username=user1,password=pass1"},
303+
//"Arg": {arg: "username=user1,password=pass1"},
304304
}
305305

306306
expconfig := Config{
@@ -333,7 +333,7 @@ func TestOptionTrendAsNativeHistogram(t *testing.T) {
333333
}{
334334
"JSON": {jsonRaw: json.RawMessage(`{"trendAsNativeHistogram":true}`)},
335335
"Env": {env: map[string]string{"K6_PROMETHEUS_TREND_AS_NATIVE_HISTOGRAM": "true"}},
336-
"Arg": {arg: "trendAsNativeHistogram=true"},
336+
//"Arg": {arg: "trendAsNativeHistogram=true"},
337337
}
338338

339339
expconfig := Config{
@@ -367,7 +367,7 @@ func TestOptionPushInterval(t *testing.T) {
367367
}{
368368
"JSON": {jsonRaw: json.RawMessage(`{"pushInterval":"1m2s"}`)},
369369
"Env": {env: map[string]string{"K6_PROMETHEUS_PUSH_INTERVAL": "1m2s"}},
370-
"Arg": {arg: "pushInterval=1m2s"},
370+
//"Arg": {arg: "pushInterval=1m2s"},
371371
}
372372

373373
expconfig := Config{

0 commit comments

Comments
 (0)