X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=pkg%2Fxapp%2Fdb.go;h=542c755768f5a5fc4ff7263d3050e48568646dd5;hb=d969b203c9d3b7e3bbf98257ed17edaddd2453b1;hp=f2286b4ae694c05c933f76540921d4de734f3fc6;hpb=775722c877ef7110cdb4e992f5c216e0e03775c4;p=ric-plt%2Fxapp-frame.git

diff --git a/pkg/xapp/db.go b/pkg/xapp/db.go
index f2286b4..542c755 100755
--- a/pkg/xapp/db.go
+++ b/pkg/xapp/db.go
@@ -70,8 +70,8 @@ func (s *SDLClient) IsReady() bool {
 	return s.ready
 }
 
-func (s *SDLClient) Store(key string, value interface{}) (err error) {
-	err = s.db.Set(key, value)
+func (s *SDLClient) doSet(pairs ...interface{}) (err error) {
+	err = s.db.Set(pairs)
 	if err != nil {
 		s.UpdateStatCounter("StoreError")
 	} else {
@@ -80,9 +80,24 @@ func (s *SDLClient) Store(key string, value interface{}) (err error) {
 	return
 }
 
+func (s *SDLClient) Store(key string, value interface{}) (err error) {
+	return s.doSet(key, value)
+}
+
+func (s *SDLClient) MStore(pairs ...interface{}) (err error) {
+	return s.doSet(pairs)
+}
+
 func (s *SDLClient) Read(key string) (value map[string]interface{}, err error) {
-	value, err = s.db.Get([]string{key})
-	return
+	return s.db.Get([]string{key})
+}
+
+func (s *SDLClient) MRead(key []string) (value map[string]interface{}, err error) {
+	return s.db.Get(key)
+}
+
+func (s *SDLClient) ReadAllKeys(key string) (value []string, err error) {
+	return s.db.GetAll()
 }
 
 func (s *SDLClient) Subscribe(cb func(string, ...string), channel string) error {