From 5617bed5257506d3dfda8537b16f44b3e40f1b42 Mon Sep 17 00:00:00 2001
From: "Douglas B. Rumbaugh" <doug@douglasrumbaugh.com>
Date: Sun, 22 Dec 2024 13:00:19 -0500
Subject: Began overhauling reconstruction mechanism

---
 .../reconstruction/ReconstructionPolicy.h          | 30 ++++++++++++++++++++++
 1 file changed, 30 insertions(+)
 create mode 100644 include/framework/reconstruction/ReconstructionPolicy.h

(limited to 'include/framework/reconstruction/ReconstructionPolicy.h')

diff --git a/include/framework/reconstruction/ReconstructionPolicy.h b/include/framework/reconstruction/ReconstructionPolicy.h
new file mode 100644
index 0000000..976091e
--- /dev/null
+++ b/include/framework/reconstruction/ReconstructionPolicy.h
@@ -0,0 +1,30 @@
+/*
+ * include/framework/reconstruction/ReconstructionPolicy.h
+ *
+ * Reconstruction class interface, used to implement custom reconstruction
+ * policies.
+ *
+ * Copyright (C) 2023-2024 Douglas B. Rumbaugh <drumbaugh@psu.edu>
+ *                         Dong Xie <dongx@psu.edu>
+ *
+ * Distributed under the Modified BSD License.
+ *
+ */
+#pragma once
+
+#include "util/types.h"
+#include "framework/structure/ExtensionStructure.h"
+#include "framework/scheduling/Epoch.h"
+
+namespace de {
+template<ShardInterface ShardType, QueryInterface<ShardType> QueryType>
+class ReconstructionPolicy {
+  typedef ExtensionStructure<ShardType, QueryType> StructureType;
+
+public:
+  ReconstructionPolicy() {}
+  virtual ReconstructionVector get_reconstruction_tasks(Epoch<ShardType, QueryType> *epoch, 
+                                                        size_t incoming_reccnt) = 0;
+  virtual ReconstructionTask get_flush_task(Epoch<ShardType, QueryType> *epoch) = 0;
+  };
+}
-- 
cgit v1.2.3