Controller

class hivemind.RootController(**kwargs)

Basic impl of subscription service handler

classmethod deregister_node(node)

Dismantel a node

classmethod enable_node(node)

Enable the node

classmethod exec_(logging=None)

Generic call used by most entry scripts to start the root without having to create a custom local instance

classmethod register_node(node)

Add the node to our root (if not already there). If it is, we simply ignore the request.

classmethod register_service(service) → dict

Register a service. This is called from a _Node

Parameters

service – The _Service instance that contains the required info.

Returns

dict

classmethod register_subscription(subscription) → dict

Register a subscription. This is called from a _Node

Parameters

subscription – The _Subscription instance that contains the required info.

Returns

dict

run(loop=None)

Our run operation is built to handle the various incoming requests and respond to the required items in time.

classmethod send_to_controller(service, payload)

Utility for shipping messages to our controller which will then route to the various subscribers (alternate thread)