Subscription Creation Events Handling

Owned by Luke Gleeson (Unlicensed)
Last updated: Feb 20, 2023
3 min read

References



https://lf-onap.atlassian.net/wiki/display/DW/CPS+Data+Notifications+Overview - Update Diagram

https://lf-onap.atlassian.net/wiki/display/DW/CPS-1065+Spike%3A+CM+data+notifications+from+NCMP+to+applications+including+subscriptions

Assumptions

Assumption

Notes

Assumption

Notes

1

All information included in the subscription event will be forwarded



2

org.onap.ncmp:cm-avc-subscription-event.response will be received from the DMI as per CPS-1065 Spike: CM data notifications from NCMP to applications including subscriptions#SubscriptionSteps



Events

Forward Subscription Event

Follow up Implementation Proposal Page: CPS-1431: Forward Subscription Information to DMI Plugin(s)

CPS-1431: Forward Subscription Information to DMI Plugin(s)Closed

  1. At the moment, it is up to the DMI Plugins to accept or reject

  2. NCMP has to reject if cached dataspace is used (Cached is currently not supported)



  3. AVC Subscription Forwarding

    { "version": "1.0", "eventType": "subscriptionCreated", "event": { "subscription": { "clientID": "SCO-9989752", "name": "cm-subscription-001" }, "dataType": { "dataspace": "ALL", "dataCategory": "CM", "dataProvider": "CM-SERVICE" "schemaName": "org.onap.ncmp:cm-network-avc-event.rfc8641" "schemaVersion": "1.0" }, "predicates": { "datastore": “passthrough-operational", "datastore-xpath-filter": "//_3gpp-nr-nrm-gnbdufunction:GNBDUFunction/ _3gpp-nr-nrm-nrcelldu:NRCellDU/ | //_3gpp-nr-nrm-gnbcuupfunction:GNBCUUPFunction// | //_3gpp-nr-nrm-gnbcucpfunction:GNBCUCPFunction/_3gpp-nr-nrm-nrcelldu:NRCellCU// | //_3gpp-nr-nrm-nrsectorcarrier:NRSectorCarrier//” } }



Subscription Event Responses

CPS-1492: Subscription Create Response HandlingClosed

  1. NCMP will be aware of the registered DMIs and the CMHandles registered to a given DMI

    1. Therefore will know how many DMIs to be waiting for a response from

    2. Wait for timeout before sending event outcome? (30s)

Subscription Event Outcome

  1. NCMP is to collate Event Responses from DMI and send.

  2. Wait for timeout,

    1. if all DMIs returned send full Event Outcome

    2. else partial event outcomes

Component Diagram

Issues & Decisions

Issue

Notes 

Decision

Issue

Notes 

Decision

1

Is the forwarding being done via an endpoint or an asynchronous kafka message

  1. Doing via endpoint will make it complicated to forward to multiple DMIs

  2. New endpoint will have to be implemented on DMI

  3. Propose org.onap.ncmp:cm-avc-subscription-event.forward



2

Extra data needed for forwarded message? What is the schema

  1.  

    1.  

      1.  

        1. ID?

        2. timestamp?

AVC Subscription Forwarding
{ "$id": "urn:cps:org.onap.cps.ncmp.events:avc-subscription-event.forward:v1", "$timestamp": "0000" "$forwardedSubscriptionEvent": { "version": "1.0", "eventType": "subscriptionCreated", "event": { "subscription": { "clientID": "SCO-9989752", "name": "cm-subscription-001" }, "dataType": { "dataspace": "ALL", "dataCategory": "CM", "dataProvider": "CM-SERVICE" "schemaName": "org.onap.ncmp:cm-network-avc-event.rfc8641" "schemaVersion": "1.0" }, "predicates": { "datastore": “passthrough-operational", "datastore-xpath-filter": "//_3gpp-nr-nrm-gnbdufunction:GNBDUFunction/ _3gpp-nr-nrm-nrcelldu:NRCellDU/ | //_3gpp-nr-nrm-gnbcuupfunction:GNBCUUPFunction// | //_3gpp-nr-nrm-gnbcucpfunction:GNBCUCPFunction/_3gpp-nr-nrm-nrcelldu:NRCellCU// | //_3gpp-nr-nrm-nrsectorcarrier:NRSectorCarrier//” } } }





AVC Subscription Forwarding
{ "$id": "urn:cps:org.onap.cps.ncmp.events:avc-subscription-event.forward:v1", "$timestamp": "0000" "$forwardedSubscriptionEvent": { "version": "1.0", "eventType": "subscriptionCreated", "event": { "subscription": { "clientID": "SCO-9989752", "name": "cm-subscription-001" }, "dataType": { "dataspace": "ALL", "dataCategory": "CM", "dataProvider": "CM-SERVICE" "schemaName": "org.onap.ncmp:cm-network-avc-event.rfc8641" "schemaVersion": "1.0" }, "predicates": { "datastore": “passthrough-operational", "datastore-xpath-filter": "//_3gpp-nr-nrm-gnbdufunction:GNBDUFunction/ _3gpp-nr-nrm-nrcelldu:NRCellDU/ | //_3gpp-nr-nrm-gnbcuupfunction:GNBCUUPFunction// | //_3gpp-nr-nrm-gnbcucpfunction:GNBCUCPFunction/_3gpp-nr-nrm-nrcelldu:NRCellCU// | //_3gpp-nr-nrm-nrsectorcarrier:NRSectorCarrier//” } } }



3

Error Scenarios

  1. DMI Rejects Predicates

  2. Error Codes

Not in scope: Future story for notifying clients that subscription failed to be created



4

Review Diagram in CPS Data Notifications Overview