The congress.dse2.control_bus Module¶
-
class
congress.dse2.control_bus.DseNodeControlBus(node)¶ Bases:
congress.dse2.data_service.DataServiceMaintain 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)¶