...
Active Subscriptions model imported from Database
SubscriptionId | cmHandle | filter | datastore |
|---|---|---|---|
| A-10 | ch-1 | p1/c1 | ncmp-datastore:passthrough-operational |
| A-10 | ch-1 | p2/c2 | ncmp-datastore:passthrough-operational |
| A-10 | ch-2 | p1/c1 | ncmp-datastore:passthrough-operational |
| A-10 | ch-2 | p2/c2 | ncmp-datastore:passthrough-operational |
Pending Subscriptions saved in CmSubscriptionCache
SubscriptionId | dmi-plugin | affectedCmHandles | status |
|---|---|---|---|
| A-10 | dmi-1 | ["ch-1","ch-2"] | PENDING |
| A-10 | dmi-2 | ["ch-3"] | PENDING |
Wide Net → Narrow Net method
| Drawio | ||||||||||||||||||||
|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|
|
B:
Reuse CmSubscriptionCacheObject model to store "PENDING" subscriptions
IMap<String, CmSubscriptionCacheObject> pendingCmSubscriptions
Map of Subscription Id and CmSubscriptionCacheObject
C:
| Drawio | ||||||||||||||||||||
|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|
|