x
/
stacktach-quincy
Code Issues Proposed changes

Adds support for /streams/count 

Returns the number of streams matching filters.

Change-Id: I5bf4a9d54ea23aa89b0b90777abce1bc8d02dcbb
This commit is contained in:
Sandy Walsh 2015-01-27 10:46:49 -08:00
parent 9c30effd93
commit a0617e4414
2 changed files with 30 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

26
quincy/v1_api.py
View File

@ -72,6 +72,29 @@ class StreamItem(common.FalconBase):
self.impl.reset_stream(stream_id)
class StreamCount(common.FalconBase):
def on_get(self, req, resp):
older_than = req.get_param('older_than')
younger_than = req.get_param('younger_than')
state = req.get_param('state')
trigger = req.get_param('trigger_name')
traits = req.get_param('distinguishing_traits')
if older_than:
older_than = parser.parse(older_than)
if younger_than:
younger_than = parser.parse(younger_than)
streams = self.impl.get_streams(count=True,
older_than=older_than,
younger_than=younger_than,
state=state,
trigger_name=trigger,
distinguishing_traits=traits)
resp.body = jsonutil.dumps(streams)
class Schema(object):
def _v(self):
return "/v%d" % self.version
@ -83,8 +106,11 @@ class Schema(object):
self.stream_collection = StreamCollection(impl)
self.stream_item = StreamItem(impl)
self.stream_count = StreamCount(impl)
self.api.add_route('%s/streams' % self._v(),
self.stream_collection)
self.api.add_route('%s/streams/{stream_id}' % self._v(),
self.stream_item)
self.api.add_route('%s/streams/count' % self._v(),
self.stream_count)

4
quincy/v1_impl.py
View File

@ -60,12 +60,16 @@ class Impl(object):
def get_streams(self, **kwargs):
"""kwargs may be:
count: True/False
older_than
younger_than
state
trigger_name
distinquishing_traits
"""
if 'count' in kwargs:
return [{"count": 3}]
x = [Stream(1000, "EOD-Exists", "Collecting"),
Stream(1001, "EOD-Exists", "Error"),
Stream(1002, "Request-ID", "Ready")]