Signed-off-by: khemendra kumar <khemendra.kumar@huawei.com>
Change-Id: I17f2e5c6f1d1b06d87b282a6f31804928fe59f6f
opts := []registry.PluginOp{
registry.OpGet(registry.WithStrKey("/cse-sr/etsi/subscribe/"+appInstanceId), registry.WithPrefix()),
}
opts := []registry.PluginOp{
registry.OpGet(registry.WithStrKey("/cse-sr/etsi/subscribe/"+appInstanceId), registry.WithPrefix()),
}
resp, err := backend.Registry().TxnWithCmp(context.Background(), opts, nil, nil)
if err != nil {
log.Errorf(err, "get subscription from etcd failed")
resp, err := backend.Registry().TxnWithCmp(context.Background(), opts, nil, nil)
if err != nil {
log.Errorf(err, "get subscription from etcd failed")
t.SetFirstErrorCode(SubscriptionNotFound, "get subscription failed, subscription not exist")
return workspace.TaskFinish
}
t.SetFirstErrorCode(SubscriptionNotFound, "get subscription failed, subscription not exist")
return workspace.TaskFinish
}
subs := make([]*models.SerAvailabilityNotificationSubscription, 0, len(values))
for _, val := range values {
sub := &models.SerAvailabilityNotificationSubscription{}
subs := make([]*models.SerAvailabilityNotificationSubscription, 0, len(values))
for _, val := range values {
sub := &models.SerAvailabilityNotificationSubscription{}
}
subs = append(subs, sub)
}
}
subs = append(subs, sub)
}
t.HttpRsp = subs
return workspace.TaskFinish
}
t.HttpRsp = subs
return workspace.TaskFinish
}