crossbar.edge.node.management

Classes

NodeManagementBridgeSession	The management bridge is a WAMP session that lives on the local management router,
NodeManagementSession	This session is used for the uplink connection to

Module Contents

class NodeManagementBridgeSession(config)

Bases: autobahn.twisted.wamp.ApplicationSession

The management bridge is a WAMP session that lives on the local management router, but has access to a 2nd WAMP session that lives on the uplink CFC router.

The bridge is responsible for forwarding calls from CFC into the local node, and for forwarding events from the local node to CFC.

_authmethod = 'trusted'

_authrole = 'trusted'

_heartbeat = 0

_heartbeat_call = None

_heartbeat_time_ns = None

_management_realm = None

_manager = None

_node_id = None

_regs

_send_heartbeat()

_start_call_forwarding()

_start_cfc_heartbeat()

_start_event_forwarding()

_stop_call_forwarding()

_stop_cfc_heartbeat()

_stop_event_forwarding()

_sub_on_mgmt = None

_sub_on_reg_create = None

_sub_on_reg_delete = None

_translate_uri(uri)

Translate a local URI (one that is used on the local node management router) to a remote URI (one used on the uplink management session at the CFC router for the management realm).

Example

crossbar.worker.worker-001.start_manhole

->

crossbarfabriccenter.node.<node_id>.worker.<worker_id>.start_manhole

attach_manager(manager, management_realm, node_id)

Attach management uplink session when the latter has been fully established and is ready to be used.

Parameters:

• manager (instance of autobahn.wamp.protocol.ApplicationSession) – uplink session.

• management_realm (unicode) – The management realm that was assigned by CFC to this node.

• node_id (unicode) – The node ID that was assigned by CFC to this node.

detach_manager()

Detach management uplink session (eg when that session has been lost).

log

onJoin(details)

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

class NodeManagementSession(runner, config=None)

Bases: autobahn.twisted.wamp.ApplicationSession

This session is used for the uplink connection to Crossbar.io Master.

_runner

log

onChallenge(challenge)

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

onConnect()

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

onDisconnect()

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

onJoin(details)

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

onLeave(details)

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

onUserError(fail, msg)

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