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

fix: Use modern form of read_window_aggregate (#8098) 

Co-authored-by: kodiakhq[bot] <49736102+kodiakhq[bot]@users.noreply.github.com>
pull/24376/head
Andrew Lamb 2023-06-28 13:49:17 -04:00 committed by GitHub
parent ac9cc24315
commit 33be68477f
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 21 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

24
influxdb_iox/src/commands/storage.rs
View File

@ -328,15 +328,33 @@ pub async fn command(connection: Connection, config: Config) -> Result<()> {
}
}
Command::ReadWindowAggregate(rwa) => {
use generated_types::influxdata::platform::storage::Duration;
use generated_types::influxdata::platform::storage::Window;
// use the window form of the RPC request to match what is used in
// influx cloud (and ignore window_every and window_offset);
let window_every = std::time::Duration::from_nanos(0);
let offset = std::time::Duration::from_nanos(0);
let window = Window {
every: Some(Duration {
nsecs: rwa.window_every.as_nanos() as i64,
months: 0,
negative: false,
}),
offset: Some(Duration {
nsecs: rwa.offset.as_nanos() as i64,
months: 0,
negative: false,
}),
};
let request = request::read_window_aggregate(
source,
config.start,
config.stop,
predicate,
rwa.window_every,
rwa.offset,
window_every,
offset,
rwa.aggregate,
None, // TODO(edd): determine if window needs to be set
Some(window),
)
.context(RequestSnafu)?;
info!(?request, "read_window_aggregate");