X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=pkg%2Fxapp%2Fsubscription.go;h=6ceabf98b802dc29e2787fb114ad1e229b98c4e7;hb=refs%2Fchanges%2F20%2F2920%2F1;hp=ffc34fbd8861b6b42294bb60d53c6f728d1841ae;hpb=429da19d53224135082f8b6f65470ae3ee8df176;p=ric-plt%2Fxapp-frame.git diff --git a/pkg/xapp/subscription.go b/pkg/xapp/subscription.go index ffc34fb..6ceabf9 100755 --- a/pkg/xapp/subscription.go +++ b/pkg/xapp/subscription.go @@ -45,7 +45,7 @@ import ( "gerrit.o-ran-sc.org/r/ric-plt/xapp-frame/pkg/restapi/operations/report" ) -type SubscriptionHandler func(models.SubscriptionType, interface{}) (models.SubscriptionResponse, error) +type SubscriptionHandler func(models.SubscriptionType, interface{}) (*models.SubscriptionResponse, error) type SubscriptionQueryHandler func() (models.SubscriptionList, error) type SubscriptionDeleteHandler func(string) error @@ -135,22 +135,22 @@ func (r *Subscriber) Listen(add SubscriptionHandler, get SubscriptionQueryHandle } // Subscription interface for xApp: REPORT -func (r *Subscriber) SubscribeReport(p *apimodel.ReportParams) (apimodel.SubscriptionResponse, error) { +func (r *Subscriber) SubscribeReport(p *apimodel.ReportParams) (*apimodel.SubscriptionResponse, error) { params := apireport.NewSubscribeReportParamsWithTimeout(r.timeout).WithReportParams(p) result, err := r.CreateTransport().Report.SubscribeReport(params) if err != nil { - return apimodel.SubscriptionResponse{}, err + return &apimodel.SubscriptionResponse{}, err } return result.Payload, err } // Subscription interface for xApp: POLICY -func (r *Subscriber) SubscribePolicy(p *apimodel.PolicyParams) (apimodel.SubscriptionResponse, error) { +func (r *Subscriber) SubscribePolicy(p *apimodel.PolicyParams) (*apimodel.SubscriptionResponse, error) { params := apipolicy.NewSubscribePolicyParamsWithTimeout(r.timeout).WithPolicyParams(p) result, err := r.CreateTransport().Policy.SubscribePolicy(params) if err != nil { - return apimodel.SubscriptionResponse{}, err + return &apimodel.SubscriptionResponse{}, err } return result.Payload, err