master package¶

Subpackages¶

Submodules¶

master.models module¶

master.models.do_connect()[source]¶

Module contents¶

class master.Master[source]¶

Bases: object

The master class watches the database for changes, queues and handles amqp messages, and handles VM image conversions

AMQP_BROADCAST_XCHG = 'broadcast'¶

AMQP_SLAVE_QUEUE = 'slaves'¶

AMQP_SLAVE_STATUS_QUEUE = 'slave_status'¶

handle_signal(sig, frame)[source]¶

TODO: Docstring for handle_signal.

Sig:	TODO
Frame:	TODO
Returns:	TODO

classmethod instance()[source]¶

Return the singleton instance of the Master class :returns: TODO

run()[source]¶

Run the master daemon :returns: TODO

stop()[source]¶

Stop the master service from running :returns: TODO

class master.TalusDBWatcher(parent_log=None, *args, **kwargs)[source]¶

Bases: master.lib.mongo_oplog_watcher.OplogWatcher

A class to watch the mongodb for changes

add_watcher(collection, watcher)[source]¶

delete(ns, ts, id, raw, **kwargs)[source]¶

Handle new deletions in the database

Ns:	TODO
Ts:	TODO
Id:	TODO
Raw:	TODO
**kwargskwargs:	TODO
Returns:	TODO

insert(ns, ts, id, obj, raw, **kwargs)[source]¶

Handle new insertions into the database

Ns:	TODO
Ts:	TODO
Id:	TODO
Obj:	TODO
Raw:	TODO
**kwargskwargs:	TODO
Returns:	TODO

run()[source]¶

stop()[source]¶

Stop the database watcher :returns: TODO

update(ns, ts, id, mod, raw, **kwargs)[source]¶

Handle new updates in the database

Ns:	TODO
Ts:	TODO
Id:	TODO
Mod:	TODO
Raw:	TODO
**kwargskwargs:	TODO
Returns:	TODO

master.main()[source]¶