diff options
Diffstat (limited to 'datastore/store/processor.py')
| -rw-r--r-- | datastore/store/processor.py | 16 |
1 files changed, 0 insertions, 16 deletions
diff --git a/datastore/store/processor.py b/datastore/store/processor.py deleted file mode 100644 index 9d39d9a..0000000 --- a/datastore/store/processor.py +++ /dev/null @@ -1,16 +0,0 @@ -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) - |