1 files changed, 16 insertions, 0 deletions
diff --git a/heap/datastore/store/processor.py b/heap/datastore/store/processor.py
new file mode 100644
index 0000000..9d39d9a
--- /dev/null
+++ b/heap/datastore/store/processor.py
@@ -0,0 +1,16 @@
+class IProcessor:
+    def __init__(self): raise NotImplementedError()
+    def process(self, name, timestamp, data, controller): pass
+
+class CountingProcessor(IProcessor):
+    def __init__(self, destination):
+        self.destination = destination
+
+    def process(self,name,timestamp,data,controller):
+        current = controller.get(self.destination,None)
+        if not current:
+            current = 0
+        current = int(current)
+
+        controller.put(self.destination, timestamp, current + 1)
+