Skip to content

Commit d9d2235

Browse files
author
Devdutt Shenoi
committed
fix: last hour window
1 parent 35561e9 commit d9d2235

File tree

1 file changed

+6
-10
lines changed

1 file changed

+6
-10
lines changed

src/prism/logstream/mod.rs

Lines changed: 6 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -214,17 +214,13 @@ pub struct PrismDatasetResponse {
214214
}
215215

216216
/// Request parameters for retrieving Prism dataset information.
217-
/// Defines which streams to query and the time range for the query.
217+
/// Defines which streams to query
218218
#[derive(Deserialize)]
219219
#[serde(rename_all = "camelCase")]
220220
pub struct PrismDatasetRequest {
221221
/// List of stream names to query
222222
#[serde(default)]
223223
streams: Vec<String>,
224-
/// ISO 8601 formatted start time or human-readable time expression
225-
start_time: String,
226-
/// ISO 8601 formatted end time or human-readable time expression
227-
end_time: String,
228224
}
229225

230226
impl PrismDatasetRequest {
@@ -283,8 +279,8 @@ impl PrismDatasetRequest {
283279
};
284280
let records = CountsRequest {
285281
stream: stream.clone(),
286-
start_time: self.start_time.clone(),
287-
end_time: self.end_time.clone(),
282+
start_time: "1h".to_owned(),
283+
end_time: "now".to_owned(),
288284
num_bins: 1,
289285
}
290286
.get_bin_density()
@@ -331,13 +327,13 @@ impl PrismDatasetRequest {
331327
) -> Result<Vec<String>, QueryError> {
332328
let query = Query {
333329
query: format!("SELECT DISTINCT({field}) FOR {stream_name}"),
334-
start_time: self.start_time.clone(),
335-
end_time: self.end_time.clone(),
330+
start_time: "1h".to_owned(),
331+
end_time: "now".to_owned(),
336332
send_null: false,
337333
filter_tags: None,
338334
fields: true,
339335
};
340-
let time_range = TimeRange::parse_human_time(&self.start_time, &self.end_time)?;
336+
let time_range = TimeRange::parse_human_time("1h", "now")?;
341337

342338
let session_state = QUERY_SESSION.state();
343339
let query = into_query(&query, &session_state, time_range).await?;

0 commit comments

Comments
 (0)