X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;ds=sidebyside;f=internal%2Fsdlgoredis%2Fsdlgoredis.go;h=574e7b0a601a9c9b8513a64c56de14fa8c947b84;hb=refs%2Fheads%2FAmber;hp=f1c7e62ea4ee685d37d82807c5383b28a5a9214e;hpb=33fdc5897e5a97acd2b866c3f01af8151f40fda3;p=ric-plt%2Fsdlgo.git diff --git a/internal/sdlgoredis/sdlgoredis.go b/internal/sdlgoredis/sdlgoredis.go index f1c7e62..574e7b0 100644 --- a/internal/sdlgoredis/sdlgoredis.go +++ b/internal/sdlgoredis/sdlgoredis.go @@ -15,6 +15,11 @@ limitations under the License. */ +/* + * This source code is part of the near-RT RIC (RAN Intelligent Controller) + * platform project (RICP). + */ + package sdlgoredis import ( @@ -92,7 +97,7 @@ func checkIntResultAndError(result interface{}, err error) (bool, error) { if err != nil { return false, err } - if result.(int64) == int64(1) { + if result.(int) == int(1) { return true, nil } return false, nil @@ -183,7 +188,7 @@ func (db *DB) UnsubscribeChannelDB(channels ...string) { } } -func (db *DB) SubscribeChannelDB(cb ChannelNotificationCb, channelPrefix, eventSeparator string, channels ...string) { +func (db *DB) SubscribeChannelDB(cb func(string, ...string), channelPrefix, eventSeparator string, channels ...string) { if len(db.cbMap) == 0 { for _, v := range channels { db.cbMap[v] = cb