Subscription Creation Events Handling

References

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

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

Assumptions

Events

Forward Subscription Event

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

CPS-1431 - Getting issue details... STATUS

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 Expand source

   {
     "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 - Getting issue details... STATUS

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

{
"$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//”  
 
    }
}
} 	

{
"$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//”  
 
    }
}
}