Influxdata
/
influxdb
mirror of https://github.com/influxdata/influxdb.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

fix: Rename influxdb2_client query to query_raw

pull/24376/head
Carol (Nichols || Goulding) 2022-09-09 11:29:18 -04:00
parent 0d313a4579
commit f7a1937f96
No known key found for this signature in database
GPG Key ID: E907EE5A736F87D4
2 changed files with 9 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
influxdb2_client/examples/query.rs
View File

@ -11,7 +11,7 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
client.query_suggestions_name("some-name").await?;
client
.query("some-org", Some(Query::new("some-query".to_string())))
.query_raw("some-org", Some(Query::new("some-query".to_string())))
.await?;
client

16
influxdb2_client/src/api/query.rs
View File

@ -61,8 +61,8 @@ impl Client {
}
}
/// Query
pub async fn query(&self, org: &str, query: Option<Query>) -> Result<String, RequestError> {
/// Query and return the raw string data from the server
pub async fn query_raw(&self, org: &str, query: Option<Query>) -> Result<String, RequestError> {
let req_url = format!("{}/api/v2/query", self.url);
let response = self
@ -189,7 +189,7 @@ mod tests {
}
#[tokio::test]
async fn query() {
async fn query_raw() {
let token = "some-token";
let org = "some-org";
let query: Option<Query> = Some(Query::new("some-influx-query-string".to_string()));
@ -207,13 +207,13 @@ mod tests {
let client = Client::new(&mockito::server_url(), token);
let _result = client.query(org, query).await;
let _result = client.query_raw(org, query).await;
mock_server.assert();
}
#[tokio::test]
async fn query_opt() {
async fn query_raw_opt() {
let token = "some-token";
let org = "some-org";
let query: Option<Query> = None;
@ -232,7 +232,7 @@ mod tests {
let client = Client::new(&mockito::server_url(), token);
let _result = client.query(org, None).await;
let _result = client.query_raw(org, None).await;
mock_server.assert();
}
@ -323,7 +323,7 @@ mod tests {
}
#[tokio::test]
async fn query_no_results() {
async fn query_raw_no_results() {
let token = "some-token";
let org = "some-org";
let query: Option<Query> = Some(Query::new("some-influx-query-string".to_string()));
@ -342,7 +342,7 @@ mod tests {
let client = Client::new(&mockito::server_url(), token);
let result = client.query(org, query).await.expect("request success");
let result = client.query_raw(org, query).await.expect("request success");
assert_eq!(result, "");
mock_server.assert();