congress.dse2.datasource_manager module¶

class congress.dse2.datasource_manager.DSManagerEndpoints(service)¶

Bases: object

add_datasource(context, items)¶

delete_datasource(context, datasource)¶

class congress.dse2.datasource_manager.DSManagerService(service_id)¶

Bases: congress.dse2.data_service.DataService

A proxy service to datasource managing methods in dse_node.

add_datasource(item, deleted=False, update_db=True)¶

delete_datasource(datasource, update_db=True)¶

register_synchronizer()¶

start()¶

Start the DataService.

This method is called by a DseNode before any RPCs are invoked.

stop()¶

Stop the DataService.

This method is called by a DseNode when the DataService instance is no longer needed. No RPCs will invoked on stopped DataServices.