Code Review
/
ric-plt
/
appmgr.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
review
|
tree
raw
|
inline
| side by side
Improve appmgr UT coverage
[ric-plt/appmgr.git]
/
pkg
/
resthooks
/
resthooks.go
diff --git
a/pkg/resthooks/resthooks.go
b/pkg/resthooks/resthooks.go
index
dea70c9
..
9ac49f9
100755
(executable)
--- a/
pkg/resthooks/resthooks.go
+++ b/
pkg/resthooks/resthooks.go
@@
-33,9
+33,13
@@
import (
)
func NewResthook(restoreData bool) *Resthook {
)
func NewResthook(restoreData bool) *Resthook {
+ return createResthook(restoreData, sdl.NewSdlInstance("appmgr", sdl.NewDatabase()))
+}
+
+func createResthook(restoreData bool, sdlInst iSdl) *Resthook {
rh := &Resthook{
client: &http.Client{},
rh := &Resthook{
client: &http.Client{},
- db: sdl
.NewSdlInstance("appmgr", sdl.NewDatabase())
,
+ db: sdl
Inst
,
}
if restoreData {
}
if restoreData {
@@
-176,7
+180,6
@@
func (rh *Resthook) retry(s SubscriptionInfo, fn func() error) error {
func (rh *Resthook) StoreSubscriptions(m cmap.ConcurrentMap) {
for v := range m.Iter() {
s := v.Val.(SubscriptionInfo)
func (rh *Resthook) StoreSubscriptions(m cmap.ConcurrentMap) {
for v := range m.Iter() {
s := v.Val.(SubscriptionInfo)
-
data, err := json.Marshal(s.req)
if err != nil {
appmgr.Logger.Error("json.marshal failed: %v ", err.Error())
data, err := json.Marshal(s.req)
if err != nil {
appmgr.Logger.Error("json.marshal failed: %v ", err.Error())