for any info/changes follow me: @nickmilon

mongoUtils.tests.PubSubBench module

Created on Jul 30, 2015

@author: milon

mongoUtils.tests.PubSubBench.printif(*args)[source]
class mongoUtils.tests.PubSubBench.PubSubController(collection_name, db, max_jobs=100)[source]
_topics = ['red', 'green', 'blue']
_verbs = ['paint', 'mix']
_ackns = [0, 1, 2]
__init__(collection_name, db, max_jobs=100)[source]
monitor(seconds=30)[source]
job_factory(topic=None, verb=None, target=None, ackn=1, max_jobs=1000)[source]
monitor_jobs_posts(topic=None, verb=None, target=None, start_from_last=True, max_jobs=None)[source]
monitor_jobs_done()[source]
stop()[source]
mongoUtils.tests.PubSubBench.thread_start(target, name, daemon=True, args=(), kwargs={})[source]
mongoUtils.tests.PubSubBench.run(connection, collection_name, topic=None, verb=None, target=None, start_from_last=True, max_jobs=1000, ms=20)[source]
mongoUtils.tests.PubSubBench.ps_tests(testname, connection, collection_name='PubSubSimulate')[source]
mongoUtils.tests.PubSubBench.parse_args()[source]
mongoUtils.tests.PubSubBench.main()[source]