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")
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 = append(subs, sub)
}
+
t.HttpRsp = subs
return workspace.TaskFinish
}