...
- maintain the database of subscribers with the
- list of generic policy-filters (each policy-filter is the resource from the request json to /decision/v1 API) Policy Design and API Flow for Model Driven Control Loop per component - subscriber
- subscriber_topic for Message Router of DMaaP that uniquely identifies id should be able to globally and uniquely identify the component instance like “policies_DCAE_tca_<service-component-name>”.
- Here <service-component-name> uniquely identifies the component in DCAE”
- subscriber_topic for Message Router of DMaaP that
- either uniquely identifies the component instance like “policies_DCAE_tca_<service-component-name>”.
- or per whole DCAE like “policies_DCAE”
- option to return the policies on subscribe request
- option to have the matching /decision/v1 API that sends multiple policies per multiple policy-filters in a single query
- on policy push/delete from PAP and on the insert-update of the subscriber record
- select all subscribers that match to the pushed/deleted policies by any policy-filter
- for each affected subscriber retrieve all the latest snapshot of policies
- notify each subscriber_topic separately with the latest snapshot of policies by sending the message to Message Router of DMaaP with the topic=subscriber_topic
- there might be a need for some logic to identify the stale subscriptions by checking with the Message Router of DMaaP on the timestamps of the latest delivered/undelivered message per ach topic PDP has the subscription on
...