Skip to content

Commit 2a2b893

Browse files
committed
fix integration tests
1 parent 9b29542 commit 2a2b893

File tree

1 file changed

+21
-7
lines changed

1 file changed

+21
-7
lines changed

src/sources/http_client/integration_tests.rs

+21-7
Original file line numberDiff line numberDiff line change
@@ -96,7 +96,9 @@ async fn collected_logs_json() {
9696
endpoint: format!("{}/logs/json.json", dufs_address()),
9797
interval: INTERVAL,
9898
query: HashMap::new(),
99-
decoding: DeserializerConfig::Json,
99+
decoding: DeserializerConfig::Json {
100+
json: Default::default(),
101+
},
100102
framing: default_framing_message_based(),
101103
headers: HashMap::new(),
102104
method: HttpMethod::Get,
@@ -173,7 +175,9 @@ async fn unauthorized_no_auth() {
173175
endpoint: format!("{}/logs/json.json", dufs_auth_address()),
174176
interval: INTERVAL,
175177
query: HashMap::new(),
176-
decoding: DeserializerConfig::Json,
178+
decoding: DeserializerConfig::Json {
179+
json: Default::default(),
180+
},
177181
framing: default_framing_message_based(),
178182
headers: HashMap::new(),
179183
method: HttpMethod::Get,
@@ -191,7 +195,9 @@ async fn unauthorized_wrong_auth() {
191195
endpoint: format!("{}/logs/json.json", dufs_auth_address()),
192196
interval: INTERVAL,
193197
query: HashMap::new(),
194-
decoding: DeserializerConfig::Json,
198+
decoding: DeserializerConfig::Json {
199+
json: Default::default(),
200+
},
195201
framing: default_framing_message_based(),
196202
headers: HashMap::new(),
197203
method: HttpMethod::Get,
@@ -212,7 +218,9 @@ async fn authorized() {
212218
endpoint: format!("{}/logs/json.json", dufs_auth_address()),
213219
interval: INTERVAL,
214220
query: HashMap::new(),
215-
decoding: DeserializerConfig::Json,
221+
decoding: DeserializerConfig::Json {
222+
json: Default::default(),
223+
},
216224
framing: default_framing_message_based(),
217225
headers: HashMap::new(),
218226
method: HttpMethod::Get,
@@ -233,7 +241,9 @@ async fn tls_invalid_ca() {
233241
endpoint: format!("{}/logs/json.json", dufs_https_address()),
234242
interval: INTERVAL,
235243
query: HashMap::new(),
236-
decoding: DeserializerConfig::Json,
244+
decoding: DeserializerConfig::Json {
245+
json: Default::default(),
246+
},
237247
framing: default_framing_message_based(),
238248
headers: HashMap::new(),
239249
method: HttpMethod::Get,
@@ -254,7 +264,9 @@ async fn tls_valid() {
254264
endpoint: format!("{}/logs/json.json", dufs_https_address()),
255265
interval: INTERVAL,
256266
query: HashMap::new(),
257-
decoding: DeserializerConfig::Json,
267+
decoding: DeserializerConfig::Json {
268+
json: Default::default(),
269+
},
258270
framing: default_framing_message_based(),
259271
headers: HashMap::new(),
260272
method: HttpMethod::Get,
@@ -276,7 +288,9 @@ async fn shutdown() {
276288
endpoint: format!("{}/logs/json.json", dufs_address()),
277289
interval: INTERVAL,
278290
query: HashMap::new(),
279-
decoding: DeserializerConfig::Json,
291+
decoding: DeserializerConfig::Json {
292+
json: Default::default(),
293+
},
280294
framing: default_framing_message_based(),
281295
headers: HashMap::new(),
282296
method: HttpMethod::Get,

0 commit comments

Comments
 (0)