Bases: object
A unit of data and business logic that interfaces with the DSE.
A DataService may publish tables, subscribe to tables, and/or expose RPCs on the DSE. DataService instances are bound to a DseNode which is used for all inter-service communication.
service_id: A unique ID of the service. _published_tables_with_subscriber: A set of tables published by self
that has subscribers
Check all subscriptions for long missing update and resubscribe.
Method that returns the current seqnum & data for given table.
Method that returns the current data for the given table.
Should be overridden.
Method called when publication data arrives.
Instances will override this method.
Method called when sequenced publication data arrives.
Return list of RPC endpoint objects to be exposed for this service.
A DataService may include zero or more RPC endpoints to be exposed by the DseNode. Each endpoint object must be compatible with the oslo.messaging RPC Server.
Start the DataService.
This method is called by a DseNode before any RPCs are invoked.
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.
Method that returns subscribers list.
It returns list of services subscribed to this service data.
Method that returns subscription list.
It returns list of tuple that represents the service’s subscription. The tuple forms following format: (service_id, table_name).
Wait for processing to complete.
After a call to stop(), the DataService may have some outstanding work that has not yet completed. The wait() method blocks until all DataService processing is complete.
Bases: object
Function called on a node when an RPC request is sent.
Function called on a node when an RPC request is sent.
Echo args
Bases: object
Metadata for DataService on the DSE.