fastly_api/apis/
log_explorer_api.rs1use reqwest;
10
11use crate::apis::ResponseContent;
12use super::{Error, configuration};
13
14#[derive(Clone, Debug, Default)]
16pub struct GetLogRecordsParams {
17 pub service_id: String,
18 pub start: String,
19 pub end: String,
20 pub limit: Option<f32>,
21 pub next_cursor: Option<String>,
22 pub filter: Option<String>
23}
24
25
26#[derive(Debug, Clone, Serialize, Deserialize)]
28#[serde(untagged)]
29pub enum GetLogRecordsError {
30 UnknownValue(serde_json::Value),
31}
32
33
34pub async fn get_log_records(configuration: &mut configuration::Configuration, params: GetLogRecordsParams) -> Result<crate::models::GetLogRecordsResponse, Error<GetLogRecordsError>> {
36 let local_var_configuration = configuration;
37
38 let service_id = params.service_id;
40 let start = params.start;
41 let end = params.end;
42 let limit = params.limit;
43 let next_cursor = params.next_cursor;
44 let filter = params.filter;
45
46
47 let local_var_client = &local_var_configuration.client;
48
49 let local_var_uri_str = format!("{}/observability/log-explorer", local_var_configuration.base_path);
50 let mut local_var_req_builder = local_var_client.request(reqwest::Method::GET, local_var_uri_str.as_str());
51
52 local_var_req_builder = local_var_req_builder.query(&[("service_id", &service_id.to_string())]);
53 local_var_req_builder = local_var_req_builder.query(&[("start", &start.to_string())]);
54 local_var_req_builder = local_var_req_builder.query(&[("end", &end.to_string())]);
55 if let Some(ref local_var_str) = limit {
56 local_var_req_builder = local_var_req_builder.query(&[("limit", &local_var_str.to_string())]);
57 }
58 if let Some(ref local_var_str) = next_cursor {
59 local_var_req_builder = local_var_req_builder.query(&[("next_cursor", &local_var_str.to_string())]);
60 }
61 if let Some(ref local_var_str) = filter {
62 local_var_req_builder = local_var_req_builder.query(&[("filter", &local_var_str.to_string())]);
63 }
64 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
65 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
66 }
67 if let Some(ref local_var_apikey) = local_var_configuration.api_key {
68 let local_var_key = local_var_apikey.key.clone();
69 let local_var_value = match local_var_apikey.prefix {
70 Some(ref local_var_prefix) => format!("{} {}", local_var_prefix, local_var_key),
71 None => local_var_key,
72 };
73 local_var_req_builder = local_var_req_builder.header("Fastly-Key", local_var_value);
74 };
75
76 let local_var_req = local_var_req_builder.build()?;
77 let local_var_resp = local_var_client.execute(local_var_req).await?;
78
79 if "GET" != "GET" && "GET" != "HEAD" {
80 let headers = local_var_resp.headers();
81 local_var_configuration.rate_limit_remaining = match headers.get("Fastly-RateLimit-Remaining") {
82 Some(v) => v.to_str().unwrap().parse().unwrap(),
83 None => configuration::DEFAULT_RATELIMIT,
84 };
85 local_var_configuration.rate_limit_reset = match headers.get("Fastly-RateLimit-Reset") {
86 Some(v) => v.to_str().unwrap().parse().unwrap(),
87 None => 0,
88 };
89 }
90
91 let local_var_status = local_var_resp.status();
92 let local_var_content = local_var_resp.text().await?;
93
94 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
95 serde_json::from_str(&local_var_content).map_err(Error::from)
96 } else {
97 let local_var_entity: Option<GetLogRecordsError> = serde_json::from_str(&local_var_content).ok();
98 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
99 Err(Error::ResponseError(local_var_error))
100 }
101}
102