summaryrefslogtreecommitdiffstats
path: root/ml/Query.h
diff options
context:
space:
mode:
Diffstat (limited to 'ml/Query.h')
-rw-r--r--ml/Query.h57
1 files changed, 0 insertions, 57 deletions
diff --git a/ml/Query.h b/ml/Query.h
deleted file mode 100644
index 42a96e85..00000000
--- a/ml/Query.h
+++ /dev/null
@@ -1,57 +0,0 @@
-#ifndef QUERY_H
-#define QUERY_H
-
-#include "ml-private.h"
-
-namespace ml {
-
-class Query {
-public:
- Query(RRDDIM *RD) : RD(RD), Initialized(false) {
- Ops = RD->tiers[0].query_ops;
- }
-
- time_t latestTime() {
- return Ops->latest_time_s(RD->tiers[0].db_metric_handle);
- }
-
- time_t oldestTime() {
- return Ops->oldest_time_s(RD->tiers[0].db_metric_handle);
- }
-
- void init(time_t AfterT, time_t BeforeT) {
- Ops->init(RD->tiers[0].db_metric_handle, &Handle, AfterT, BeforeT, STORAGE_PRIORITY_BEST_EFFORT);
- Initialized = true;
- points_read = 0;
- }
-
- bool isFinished() {
- return Ops->is_finished(&Handle);
- }
-
- ~Query() {
- if (Initialized) {
- Ops->finalize(&Handle);
- global_statistics_ml_query_completed(points_read);
- points_read = 0;
- }
- }
-
- std::pair<time_t, CalculatedNumber> nextMetric() {
- points_read++;
- STORAGE_POINT sp = Ops->next_metric(&Handle);
- return {sp.end_time_s, sp.sum / sp.count };
- }
-
-private:
- RRDDIM *RD;
- bool Initialized;
- size_t points_read;
-
- struct storage_engine_query_ops *Ops;
- struct storage_engine_query_handle Handle;
-};
-
-} // namespace ml
-
-#endif /* QUERY_H */