crossbar.master.node

Submodules

Classes

DomainController

Main CFC backend for a domain (instance of CFC, all CFC nodes connected to one controller node / database).

DomainManager

Global domain backend.

Package Contents

class DomainController(config: autobahn.wamp.types.ComponentConfig | None = None)[source]

Bases: autobahn.twisted.wamp.ApplicationSession

Main CFC backend for a domain (instance of CFC, all CFC nodes connected to one controller node / database).

There is exactly one instance running per master node of a domain.

_agg_metering_mnode_logs(from_ts, until_ts, mrealm_id, by_node=False)[source]

Aggregate raw managed node and worker logs and store usage metering records.

Note: This is run on a background thread!

Parameters:

  • from_ts

  • until_ts

  • mrealm_id

  • by_node

Returns:

_agg_metering_mworker_logs(from_ts, until_ts, mrealm_id)[source]

Aggregate raw managed node and worker logs and store usage metering records.

Note: This is run on a background thread!

Parameters:

  • from_ts

  • until_ts

  • mrealm_id

  • by_node

Returns:

_do_metering(started)[source]
_first_metering(mrealm_id)[source]

Determine timestamp of first node heartbeat from any node of a given management realm.

Parameters:

mrealm_id

Returns:

_initialize()[source]
_submit_metering(started, filter_status=[1], limit=None)[source]
log
async onJoin(details)[source]

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

class DomainManager(session, db, schema)[source]

Bases: object

Global domain backend.

_db
_schema
_session
get_license(details=None)[source]

Returns CFC software stack license information.

Procedure:

crossbarfabriccenter.domain.get_license

Parameters:

details (autobahn.wamp.types.CallOptions) – Call details.

Returns:

License information, including enabled features and limits.

Return type:

dict

get_status(details=None)[source]

Get global (domain) realm status.

Procedure:

crossbarfabriccenter.domain.get_status

Parameters:

details (autobahn.wamp.types.CallOptions) – Call details.

Returns:

Global system status information.

Return type:

dict

get_version(details=None)[source]

Returns CFC software stack version information.

Procedure:

crossbarfabriccenter.domain.get_version

Parameters:

details (autobahn.wamp.types.CallOptions) – Call details.

Returns:

Information on software stack versions.

Return type:

dict

log
register(session, prefix, options)[source]