spreadflow_mongodb.proc module

class spreadflow_mongodb.proc.MongoCollectionDeltaSync(database=u'test_database', collection=u'test_collection', reset=False)

Bases: object

class spreadflow_mongodb.proc.MongoConnection(uri=u'mongodb://localhost:27017/')

Bases: object

attach(*args, **kwargs)

cmd(f, *args, **kwargs)

detach(*args, **kwargs)

reactor = None

class spreadflow_mongodb.proc.WorkerJob(d, f, *args, **kwargs)

Bases: object

run(reactor)

class spreadflow_mongodb.proc.WorkerStop(d, result=None)

Bases: object

run(reactor)