influx_client/flux/functions/
sort.rs1use std::fmt::Display;
2
3pub struct Sort<'a> {
4 columns: &'a [&'a str],
5 desc: bool,
6}
7
8impl<'a> Sort<'a> {
9 pub fn new(columns: &'a [&'a str], desc: bool) -> Self {
10 Self { columns, desc }
11 }
12}
13
14impl<'a> Display for Sort<'a> {
15 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
16 let columns = if self.columns.is_empty() {
17 String::new()
18 } else {
19 let escaped: Vec<String> = self.columns.iter().map(|c| format!("\"{c}\"")).collect();
20 format!("columns: [{}]", escaped.join(", "))
21 };
22 let desc = if self.desc {
23 "desc: true"
24 } else {
25 "desc: false"
26 };
27 write!(f, "sort({columns}, {desc})")
28 }
29}