1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
|
class Node(object):
__slots__ = ('name', 'path', 'local', 'is_leaf')
def __init__(self, path):
self.path = path
self.name = path.split('.')[-1]
self.local = True
self.is_leaf = False
def __repr__(self):
return '<%s[%x]: %s>' % (self.__class__.__name__, id(self), self.path)
class BranchNode(Node):
pass
class LeafNode(Node):
__slots__ = ('reader', )
def __init__(self, path, reader):
Node.__init__(self, path)
self.reader = reader
self.is_leaf = True
def fetch(self, startTime, endTime, now=None, requestContext=None):
try:
result = self.reader.fetch(startTime, endTime, now, requestContext)
except TypeError:
# Support for legacy 3rd party, readers.
result = self.reader.fetch(startTime, endTime)
return result
@property
def intervals(self):
return self.reader.get_intervals()
def __repr__(self):
return '<LeafNode[%x]: %s (%s)>' % (id(self), self.path, self.reader)
|
