crossbar.master.api¶

Submodules¶

Attributes¶

APIS

Classes¶

`RemoteApi`
`RemoteContainerApi`
`RemoteDockerApi`
`RemoteNodeApi`	Remote API to CF node controller.
`RemoteProxyApi`
`RemoteRouterApi`
`RemoteTracingApi`
`RemoteWampApi`	Exposes the WAMP meta API on a router realm from a remote node
`RemoteWorkerApi`

Package Contents¶

APIS: List[remote.RemoteApi | wamp.RemoteWampApi] = [][source]¶

class RemoteApi[source]¶

Bases: object

EVENTS: Dict[str, List]¶

PREFIX = 'unset'¶

PROCS: Dict[str, List]¶

log¶

register(session)[source]¶

Parameters:: session – MrealmController
Returns:

subscribe(session)[source]¶

class RemoteContainerApi[source]¶

Bases: crossbar.master.api.remote.RemoteApi

EVENTS¶

PREFIX = 'crossbarfabriccenter.remote.container.'¶

PROCS¶

class RemoteDockerApi[source]¶

Bases: crossbar.master.api.remote.RemoteApi

EVENTS¶

PREFIX = 'crossbarfabriccenter.remote.docker.'¶

PROCS¶

class RemoteNodeApi[source]¶

Bases: crossbar.master.api.remote.RemoteApi

Remote API to CF node controller.

EVENTS¶

PREFIX = 'crossbarfabriccenter.remote.node.'¶

PROCS¶

class RemoteProxyApi[source]¶

Bases: crossbar.master.api.remote.RemoteApi

EVENTS¶

PREFIX = 'crossbarfabriccenter.remote.proxy.'¶

PROCS¶

class RemoteRouterApi[source]¶

Bases: crossbar.master.api.remote.RemoteApi

EVENTS¶

PREFIX = 'crossbarfabriccenter.remote.router.'¶

PROCS¶

class RemoteTracingApi[source]¶

Bases: crossbar.master.api.remote.RemoteApi

EVENTS¶

PREFIX = 'crossbarfabriccenter.remote.tracing.'¶

PROCS¶

class RemoteWampApi[source]¶

Bases: object

Exposes the WAMP meta API on a router realm from a remote node on CFC. This is only available if the router realm is started with option.bridge_meta_api == True.

Events are published locally on the node WAMP meta API like

[1] wamp.session.on_join: (session_id, session_details)

and (if bridged), on the local node management API

[2] crossbar.worker.<worker_id>.realm.<realm_id>.root.wamp.session.on_join: (session_id, session_details)

which then get forward to CFC as

[3] crossbarfabriccenter.node.<node_id>.worker.<worker_id>.realm.<realm_id>.root.: (session_id, session_details)

which is then republished by CFC as

[4] crossbarfabriccenter.remote.realm.meta.wamp.session.on_join: (node_id, worker_id, realm_id, session_id, session_details)

For example:

[1] wamp.session.on_join [2] crossbar.worker.worker-001.realm.realm-001.root.wamp.session.on_join [3] crossbarfabriccenter.node.cf1.worker.worker-001.realm.realm-001.root.wamp.session.on_join [4] crossbarfabriccenter.remote.realm.meta.wamp.session.on_join

PREFIX = 'crossbarfabriccenter.remote.realm.meta.'¶

log¶

register(session)[source]¶

subscribe(session)[source]¶

class RemoteWorkerApi[source]¶

Bases: crossbar.master.api.remote.RemoteApi

EVENTS¶

PREFIX = 'crossbarfabriccenter.remote.worker.'¶

PROCS¶