Bases: object
Addressable entity participating on the DSE message bus.
The Data Services Engine (DSE) is comprised of one or more DseNode instances that each may run one or more DataService instances. All communication between data services uses the DseNode interface.
node_id: The unique ID of this node on the DSE. messaging_config: Configuration options for the message bus. See
oslo.messaging for more details.
Invoke RPC method on all DSE Nodes.
Raises: RemoteError, MessageDeliveryFailure
Invoke RPC method on all instances of service_id.
Raises: RemoteError, MessageDeliveryFailure
Create a new DataService on this node.
:param type_ is the kind of service :param id_ is an optional parameter for specifying the uuid.
Return latest observation of DSE status.
Return the created datasource.
Return the created datasources as recorded in the DB.
This returns what datasources the database contains, not the datasources that this server instance is running.
Return names of all services on all nodes.
Return all local service objects.
List of services subscribed to this service.
Return publisher/tables subscribed by service: service_id
Return data structure: {publisher_id -> set of tables}
Invoke RPC method on a DSE Node.
Raises: MessagingTimeout, RemoteError, MessageDeliveryFailure
Invoke RPC method on a DSE Service.
Raises: MessagingTimeout, RemoteError, MessageDeliveryFailure, NotFound
Load all configured drivers and check no name conflict
Invoke RPC method on all insances of service_id.
Raises: RemoteError, MessageDeliveryFailure
Invoke RPC method on all insances of service_id.
Raises: RemoteError, MessageDeliveryFailure
Return the service object requested.
Search by service_id or uuid_ (only one should be supplied). None if not found.
Prepare local service to receives publications from target/table.
List services on this node that subscribes to publisher/table.
Unregister service from DseNode matching on service_id or uuid_
Only one should be supplied. No-op if no matching service found.
Remove subscription for local service to target/table.
Bases: object
Collection of RPC endpoints that the DseNode exposes on the bus.
Must be a separate class since all public methods of a given class are assumed to be valid RPC endpoints.
Function called on the node when a publication is sent.
Forwards the publication to all of the relevant services.
Function called on the node when a publication is sent.
Forwards the publication to all of the relevant services.