Began overhauling reconstruction mechanism

1 files changed, 30 insertions, 0 deletions

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;
+  };
+}