summaryrefslogtreecommitdiff
path: root/heap/datastore/store/channel.py
diff options
context:
space:
mode:
authorEbus-at-dockstar <ebus@dockstar>2013-03-25 10:24:28 +0100
committerEbus-at-dockstar <ebus@dockstar>2013-03-25 10:24:43 +0100
commit862282ce99760832d3e9e5b4b1171b861105e004 (patch)
tree0e229418e391917b79d42a8bdee46fb7a8612895 /heap/datastore/store/channel.py
parent9522cdffa94f278eb5e1894600535986e22c2890 (diff)
downloadebus-alt-862282ce99760832d3e9e5b4b1171b861105e004.tar.gz
ebus-alt-862282ce99760832d3e9e5b4b1171b861105e004.zip
move old stuff away
Diffstat (limited to 'heap/datastore/store/channel.py')
-rw-r--r--heap/datastore/store/channel.py25
1 files changed, 25 insertions, 0 deletions
diff --git a/heap/datastore/store/channel.py b/heap/datastore/store/channel.py
new file mode 100644
index 0000000..1e083b5
--- /dev/null
+++ b/heap/datastore/store/channel.py
@@ -0,0 +1,25 @@
+class IChannel:
+ def __init__(self): raise NotImplementedError()
+ def add(self,timestamp,data,controller): pass
+ def get(self,query): pass
+
+class PrinterChannel(IChannel):
+ def __init__(self,name):
+ self.name = name
+ def add(self,timestamp,data,controller):
+ print "{0}: timestamp={1} value={2}".format(self.name, timestamp, data)
+
+class SimpleMemoryChannel(IChannel):
+ def __init__(self):
+ self.data = ""
+ def add(self,timestamp,data,controller):
+ self.data = data
+ def get(self,query):
+ return str(self.data)
+
+class IntervalStoreChannel(IChannel):
+ SECONDS=1000
+ MINUTES=60*1000
+ HOURS=60*60*1000
+ DAYS=24*60*60*1000
+ def __init__(self): pass