|
__init__(self)
x.__init__(...) initializes x; see x.__class__.__doc__ for signature |
source code
|
|
|
|
|
create(self,
id,
description,
consumerids=())
Create a new ConsumerGroup object and return it |
source code
|
|
|
consumergroups(self)
List all consumergroups. |
source code
|
|
|
consumergroup(self,
id)
Return a single ConsumerGroup object |
source code
|
|
|
consumers(self,
id)
Return consumer ids belonging to this ConsumerGroup |
source code
|
|
|
|
|
_add_consumer(self,
consumergroup,
consumer)
Responsible for properly associating a Consumer to a ConsumerGroup |
source code
|
|
|
|
|
bind(self,
id,
repoid)
Bind (subscribe) a consumer group to a repo. |
source code
|
|
|
unbind(self,
id,
repoid)
Unbind (unsubscribe) a consumer group from a repo. |
source code
|
|
|
|
|
|
Inherited from object :
__delattr__ ,
__getattribute__ ,
__hash__ ,
__new__ ,
__reduce__ ,
__reduce_ex__ ,
__repr__ ,
__setattr__ ,
__str__
|
|
|
|
|
|
|
|
delete(self,
**kwargs)
Delete a single stored Object |
source code
|
|
|
insert(self,
object,
check_keys=False)
Insert the object document to the database |
source code
|
|
|
update(self,
object)
Write the object document to the database |
source code
|
|