The congress.dse2.control_bus Module¶

class congress.dse2.control_bus.DseNodeControlBus(node)¶

Bases: congress.dse2.data_service.DataService

Maintain DSE connection for a DseNode.

The DSE maintains a common directory of data services and their corresponding exported tables and RPCs. This control bus maintains this view using oslo.messaging RPC primitives.

HEARTBEAT_INTERVAL = 1¶

dse_status()¶

Return latest observation of DSE status.

rpc_endpoints()¶

start()¶

stop()¶

class congress.dse2.control_bus.HeartbeatEncoder(skipkeys=False, ensure_ascii=True, check_circular=True, allow_nan=True, sort_keys=False, indent=None, separators=None, encoding='utf-8', default=None)¶

Bases: json.encoder.JSONEncoder

default(obj)¶

congress.dse2.control_bus.drop_cast_echos(wrapped)¶