From e970e0b37b8bd7f246feb3f70c4136418225e434 Mon Sep 17 00:00:00 2001
From: Daniel Baumann <daniel.baumann@progress-linux.org>
Date: Wed, 1 Dec 2021 07:15:04 +0100
Subject: Adding upstream version 1.32.0.

Signed-off-by: Daniel Baumann <daniel.baumann@progress-linux.org>
---
 ml/Query.h | 49 +++++++++++++++++++++++++++++++++++++++++++++++++
 1 file changed, 49 insertions(+)
 create mode 100644 ml/Query.h

(limited to 'ml/Query.h')

diff --git a/ml/Query.h b/ml/Query.h
new file mode 100644
index 000000000..cbaf6c297
--- /dev/null
+++ b/ml/Query.h
@@ -0,0 +1,49 @@
+#ifndef QUERY_H
+#define QUERY_H
+
+#include "ml-private.h"
+
+namespace ml {
+
+class Query {
+public:
+    Query(RRDDIM *RD) : RD(RD) {
+        Ops = &RD->state->query_ops;
+    }
+
+    time_t latestTime() {
+        return Ops->latest_time(RD);
+    }
+
+    time_t oldestTime() {
+        return Ops->oldest_time(RD);
+    }
+
+    void init(time_t AfterT, time_t BeforeT) {
+        Ops->init(RD, &Handle, AfterT, BeforeT);
+    }
+
+    bool isFinished() {
+        return Ops->is_finished(&Handle);
+    }
+
+    std::pair<time_t, storage_number> nextMetric() {
+        time_t CurrT;
+        storage_number SN = Ops->next_metric(&Handle, &CurrT);
+        return { CurrT, SN };
+    }
+
+    ~Query() {
+        Ops->finalize(&Handle);
+    }
+
+private:
+    RRDDIM *RD;
+
+    struct rrddim_volatile::rrddim_query_ops *Ops;
+    struct rrddim_query_handle Handle;
+};
+
+} // namespace ml
+
+#endif /* QUERY_H */
-- 
cgit v1.2.3