-func (u *UENIBClient) ReleaseUeContext(gNbId string, gNbUeX2ApId string) error {
- return u.writer.RemoveUeContext(gNbId, gNbUeX2ApId)
-}
-
-func (u *UENIBClient) ReadUeMeasurement(gNbId string, gNbUeX2ApId string) (*uenibprotobuf.MeasResults, error) {
- return u.reader.GetUeMeasurement(gNbId, gNbUeX2ApId)
-}
-
-func (u *UENIBClient) SubscribeEvents(gNbIDs []string, eventCategories []EventCategory, cb EventCallback) error {
- return u.reader.SubscribeEvents(gNbIDs, eventCategories, cb)
-}
-
-func NewRNIBClient(ns string) *RNIBClient {
- rnibreader.Init("e2Manager", 1)
- rnibwriter.InitWriter("e2Manager", 1)
- return &RNIBClient{
- reader: nil,
- writer: nil,
- }
+func (r *RNIBClient) StoreAndPublish(channel string, event string, pairs ...interface{}) error {
+ return r.db.SetAndPublish([]string{channel, event}, pairs...)