crossbar.master.node.node

Classes

FabricCenterNode	Crossbar.io Master node personality.
FabricServiceNodeManager	CFC Node manager. This is responsible for starting and stopping

Module Contents

class FabricCenterNode(personality, cbdir=None, reactor=None, native_workers=None, options=None)

Bases: crossbar.edge.node.node.FabricNode

Crossbar.io Master node personality.

DEFAULT_CONFIG_PATH = 'master/node/config.json'

Builtin default master node configuration.

_add_extra_controller_components(controller_options)

_add_worker_role(worker_auth_role, options)

_db = None

_license = None

_schema = None

_set_shutdown_triggers(controller_options)

_w3 = None

boot()

load_config(configfile=None)

Load the node configuration of CFC itself. The base node configuration is built into CFC, but can be overridden (partially) and extended by providing a regular, local node configuration file.

When such a file exists:

• and it contains a controller section, these take precedence over

the builtin values. - and it contains a workers section (a list of workers), these are _added_ to the builtin workers.

start(node_id=None)

Starts this node. This will start a node controller and then spawn new worker processes as needed.

The node keys (load_keys) and configuration (load_config) has to be loaded before starting the node.

This is the _third_ function being called after the Node has been instantiated.

class FabricServiceNodeManager(config, reactor, personality, node)

Bases: autobahn.twisted.wamp.ApplicationSession

CFC Node manager. This is responsible for starting and stopping management realms

_db = None

async _initialize_mrealm(mrealm)

Initializes a single management realm:

1. start a respective realm on the router worker of this master node. Currently there is only one router worker statically configured (named “cfrouter1”).

2. start a couple of roles on the management realm (see BUILTIN_ROLES) 3.

Parameters:

mrealm (cfxdb.mrealm.management_realm.ManagementRealm) – The management realm to initialize.

Returns:

async _initialize_mrealms(parallel=False)

_node

_reactor

_schema = None

_xbr = None

async activate_realm(mrealm_obj, details=None)

async deactivate_realm(mrealm_obj, details=None)

log

async onJoin(details: autobahn.wamp.types.ComponentConfig)

Implements autobahn.wamp.interfaces.ISession.onJoin()

onLeave(details)

Implements autobahn.wamp.interfaces.ISession.onLeave()

personality