-func (r *RNIBClient) GetgNBList() (values map[string]interface{}, err error) {
- keys, err := r.db.GetAll()
- if err == nil {
- values = make(map[string]interface{})
- for _, key := range keys {
- v, err := r.db.Get([]string{key})
- if err == nil {
- values[key] = v[key]
- }
- }
- }
- return
+func (r *RNIBClient) Subscribe(cb func(string, ...string), channel string) error {
+ return r.db.SubscribeChannel(cb, channel)
+}
+
+func (r *RNIBClient) StoreAndPublish(channel string, event string, pairs ...interface{}) error {
+ return r.db.SetAndPublish([]string{channel, event}, pairs...)
+}
+
+func (r *RNIBClient) GetNodeb(invName string) (*RNIBNodebInfo, RNIBIRNibError) {
+ return rnibreader.GetRNibReader(r.db).GetNodeb(invName)
+}
+
+func (r *RNIBClient) GetNodebByGlobalNbId(t RNIBNodeType, gid *RNIBGlobalNbId) (*RNIBNodebInfo, RNIBIRNibError) {
+ return rnibreader.GetRNibReader(r.db).GetNodebByGlobalNbId(t, gid)
+}
+
+func (r *RNIBClient) GetCellList(invName string) (*RNIBCells, RNIBIRNibError) {
+ return rnibreader.GetRNibReader(r.db).GetCellList(invName)
+}
+
+func (r *RNIBClient) GetListGnbIds() ([]*RNIBNbIdentity, RNIBIRNibError) {
+ return rnibreader.GetRNibReader(r.db).GetListGnbIds()
+}
+
+func (r *RNIBClient) GetListEnbIds() ([]*RNIBNbIdentity, RNIBIRNibError) {
+ return rnibreader.GetRNibReader(r.db).GetListEnbIds()