new auth
parent
f1868cd300
commit
a0b9365120
|
|
@ -194,7 +194,7 @@ impl MonitoringImporter {
|
||||||
.post(url)
|
.post(url)
|
||||||
.timeout(tokio::time::Duration::from_secs(self.timeout as u64))
|
.timeout(tokio::time::Duration::from_secs(self.timeout as u64))
|
||||||
.header("Content-Type", "application/json")
|
.header("Content-Type", "application/json")
|
||||||
.header("access-token", &self.access_token)
|
.bearer_auth(&self.access_token)
|
||||||
.json(&Query::default());
|
.json(&Query::default());
|
||||||
let resp = client.send().await?.text().await?;
|
let resp = client.send().await?.text().await?;
|
||||||
let resp: Value = serde_json::from_str(&resp)?;
|
let resp: Value = serde_json::from_str(&resp)?;
|
||||||
|
|
@ -307,7 +307,7 @@ impl MonitoringImporter {
|
||||||
.get(format!("http://{}/e-nms/mirror/measure/{}", arc.ip, &measure))
|
.get(format!("http://{}/e-nms/mirror/measure/{}", arc.ip, &measure))
|
||||||
.timeout(tokio::time::Duration::from_secs(arc.timeout as u64))
|
.timeout(tokio::time::Duration::from_secs(arc.timeout as u64))
|
||||||
.header("Content-Type", "application/json")
|
.header("Content-Type", "application/json")
|
||||||
.header("access-token", &arc.access_token)
|
.bearer_auth(&arc.access_token)
|
||||||
.send().await?
|
.send().await?
|
||||||
.text().await?;
|
.text().await?;
|
||||||
tokio::task::yield_now().await;
|
tokio::task::yield_now().await;
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue