Add mark/limit paging for streams list.
Pass mark and limit params to driver. Change-Id: Ia465eacc4c8da514f420c6489dc66960692e0726
This commit is contained in:
parent
b26cc7f04c
commit
36b4574850
|
@ -56,7 +56,7 @@ class Impl(object):
|
||||||
|
|
||||||
def get_streams(self, count=False, state=None, older_than=None,
|
def get_streams(self, count=False, state=None, older_than=None,
|
||||||
younger_than=None, trigger_name=None,
|
younger_than=None, trigger_name=None,
|
||||||
distinguishing_traits=None):
|
distinguishing_traits=None, mark=None, limit=None):
|
||||||
|
|
||||||
if state is not None:
|
if state is not None:
|
||||||
try:
|
try:
|
||||||
|
@ -67,7 +67,8 @@ class Impl(object):
|
||||||
return self.driver.find_streams(count=count,
|
return self.driver.find_streams(count=count,
|
||||||
state=state, name=trigger_name,
|
state=state, name=trigger_name,
|
||||||
younger_than=younger_than, older_than=older_than,
|
younger_than=younger_than, older_than=older_than,
|
||||||
distinguishing_traits=distinguishing_traits)
|
distinguishing_traits=distinguishing_traits,
|
||||||
|
mark=mark, limit=limit)
|
||||||
|
|
||||||
def get_stream(self, stream_id, details):
|
def get_stream(self, stream_id, details):
|
||||||
stream = int(stream_id)
|
stream = int(stream_id)
|
||||||
|
|
Loading…
Reference in New Issue