X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=pkg%2Fcontrol%2Fregistry.go;h=72a210056efaf6f97d04f9cc779261ffad13ba12;hb=refs%2Fchanges%2F52%2F6552%2F2;hp=2495d3b9ba249786977dd385d482441975de26a0;hpb=5d9b232c7d3d6aea8686ea598d5b09ef82ecd6f0;p=ric-plt%2Fsubmgr.git diff --git a/pkg/control/registry.go b/pkg/control/registry.go index 2495d3b..72a2100 100644 --- a/pkg/control/registry.go +++ b/pkg/control/registry.go @@ -20,6 +20,7 @@ package control import ( + "encoding/json" "fmt" "sync" "time" @@ -104,6 +105,16 @@ func (r *Registry) Initialize() { } } +func (r *Registry) GetAllRestSubscriptions() []byte { + r.mutex.Lock() + defer r.mutex.Unlock() + restSubscriptionsJson, err := json.Marshal(r.restSubscriptions) + if err != nil { + xapp.Logger.Error("GetAllRestSubscriptions(): %v", err) + } + return restSubscriptionsJson +} + func (r *Registry) CreateRESTSubscription(restSubId *string, xAppRmrEndPoint *string, maid *string) (*RESTSubscription, error) { r.mutex.Lock() defer r.mutex.Unlock()