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.