Skip to content

Commit 0acc071

Browse files
authored
allow getting raw aggregations (#305)
1 parent cbd340c commit 0acc071

File tree

2 files changed

+13
-0
lines changed

2 files changed

+13
-0
lines changed

src/responses/src/search.rs

Lines changed: 7 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -133,6 +133,13 @@ impl<T> SearchResponse<T> {
133133
pub fn aggs(&self) -> Aggs {
134134
Aggs::new(self.aggregations.as_ref())
135135
}
136+
137+
/**
138+
Get a reference to the raw aggregation value.
139+
*/
140+
pub fn aggs_raw(&self) -> Option<&Value> {
141+
self.aggregations.as_ref().map(|wrapper| &wrapper.0)
142+
}
136143
}
137144

138145
impl<T: DeserializeOwned> IsOk for SearchResponse<T> {

src/responses/tests/search/mod.rs

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -107,6 +107,12 @@ fn success_parse_simple_nested_aggs() {
107107
.unwrap();
108108

109109
assert_eq!(deserialized.aggs().count(), 124);
110+
111+
let doc_count = deserialized
112+
.aggs_raw()
113+
.and_then(|aggs| aggs["timechart"]["buckets"][0]["doc_count"].as_u64());
114+
115+
assert_eq!(Some(101), doc_count);
110116
}
111117

112118
#[test]

0 commit comments

Comments
 (0)