From 749726bcd7bd058ac425dd260f701a961c2d5210 Mon Sep 17 00:00:00 2001 From: Mohamed Abukar Date: Wed, 19 Aug 2020 14:23:56 +0300 Subject: [PATCH] A wrapper for RNIB event subscription Change-Id: I19439f8af09a5d6547275c39a8df2bbb2f4069b3 Signed-off-by: Mohamed Abukar --- pkg/xapp/db.go | 8 ++++++++ 1 file changed, 8 insertions(+) diff --git a/pkg/xapp/db.go b/pkg/xapp/db.go index afb52b5..6591e04 100755 --- a/pkg/xapp/db.go +++ b/pkg/xapp/db.go @@ -174,6 +174,14 @@ func NewRNIBClient(ns string) *RNIBClient { } } +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) } -- 2.16.6