X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=pkg%2Fxapp%2Fdb.go;h=b6ad9fce69646ad04b77d2bbe3c0452206295034;hb=refs%2Fchanges%2F95%2F895%2F1;hp=779e2cd559495fa54644ff0d3371399b1f3c5cd5;hpb=3e611c621fa048f5f7da7cab3d4c211b4686fcce;p=ric-plt%2Fxapp-frame.git diff --git a/pkg/xapp/db.go b/pkg/xapp/db.go index 779e2cd..b6ad9fc 100755 --- a/pkg/xapp/db.go +++ b/pkg/xapp/db.go @@ -24,9 +24,9 @@ import ( rnibentities "gerrit.o-ran-sc.org/r/ric-plt/nodeb-rnib.git/entities" rnibreader "gerrit.o-ran-sc.org/r/ric-plt/nodeb-rnib.git/reader" sdl "gerrit.o-ran-sc.org/r/ric-plt/sdlgo" - uenibprotobuf "gerrit.o-ran-sc.org/r/ric-plt/ue-nib/uernibprotobuf" - uenibreader "gerrit.o-ran-sc.org/r/ric-plt/ue-nib/uernibreader" - uenibwriter "gerrit.o-ran-sc.org/r/ric-plt/ue-nib/uernibwriter" + uenibprotobuf "gerrit.o-ran-sc.org/r/ric-plt/ue-nib/uenibprotobuf" + uenibreader "gerrit.o-ran-sc.org/r/ric-plt/ue-nib/uenibreader" + uenibwriter "gerrit.o-ran-sc.org/r/ric-plt/ue-nib/uenibwriter" rnibwriter "gerrit.o-ran-sc.org/r/ric-plt/xapp-frame/pkg/rnib" "sync" "time" @@ -159,6 +159,10 @@ func (s *SDLClient) MStoreAndPublish(channelsAndEvents []string, pairs ...interf return s.db.SetAndPublish(channelsAndEvents, pairs...) } +func (s *SDLClient) Delete(keys []string) (err error) { + return s.db.Remove(keys) +} + func (s *SDLClient) Clear() { s.db.RemoveAll() } @@ -205,8 +209,8 @@ func (u *UENIBClient) SubscribeEvents(gNbIDs []string, eventCategories []EventCa } func NewRNIBClient(ns string) *RNIBClient { - rnibreader.Init("rnib", 1) - rnibwriter.InitWriter("rnib", 1) + rnibreader.Init("e2Manager", 1) + rnibwriter.InitWriter("e2Manager", 1) return &RNIBClient{ reader: nil, writer: nil,