X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=pkg%2Fcontrol%2Fsdl_restSubsDb.go;h=a0afbc005df0eb651ab3f2ec750b5a2a25b70c1b;hb=93a5f9e27a6803adce055811c222632bfd69d11c;hp=e9a7d2f86e22ffaae304c0fa1b9e27dbb8594b17;hpb=f0bb66c95fa3f03ae956cc719cc776ed2f2f3bd4;p=ric-plt%2Fsubmgr.git diff --git a/pkg/control/sdl_restSubsDb.go b/pkg/control/sdl_restSubsDb.go index e9a7d2f..a0afbc0 100644 --- a/pkg/control/sdl_restSubsDb.go +++ b/pkg/control/sdl_restSubsDb.go @@ -96,7 +96,7 @@ func (c *Control) ReadRESTSubscriptionFromSdl(restSubId string) (*RESTSubscripti restSubs = c.CreateRESTSubscription(restSubscriptionInfo, &jsonSubscriptionInfo) - restDuplicateCtrl.SetMd5sumFromLastOkRequest(restSubId, restSubs.lastReqMd5sum) + c.restDuplicateCtrl.SetMd5sumFromLastOkRequest(restSubId, restSubs.lastReqMd5sum) } return restSubs, nil } @@ -176,3 +176,14 @@ func (c *Control) RemoveAllRESTSubscriptionsFromSdl() error { } return nil } + +func (c *Control) GetRESTKeyCount() (int, error) { + + // Get all keys + keys, err := c.restSubsDb.GetAll(restSubSdlNs) + if err != nil { + c.UpdateCounter(cSDLReadFailure) + return 0, fmt.Errorf("SDL: GetRESTKeyCount(), GetAll(). Error while reading E2 subscriptions keys from DBAAS %s\n", err.Error()) + } + return len(keys), nil +}