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)