X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=pkg%2Fclientapi%2Fcommon%2Fsubscribe_responses.go;h=a50361a2e85cb740ddcf8a1bcaf7eb4939203a1d;hb=refs%2Ftags%2Fv0.9.3;hp=db860169ef6b977656a158f24ff58d77e3257c06;hpb=c79bd0e1a4fe855b06c8f8131f162d0ee4a5f9f5;p=ric-plt%2Fxapp-frame.git diff --git a/pkg/clientapi/common/subscribe_responses.go b/pkg/clientapi/common/subscribe_responses.go index db86016..a50361a 100644 --- a/pkg/clientapi/common/subscribe_responses.go +++ b/pkg/clientapi/common/subscribe_responses.go @@ -35,12 +35,24 @@ func (o *SubscribeReader) ReadResponse(response runtime.ClientResponse, consumer return nil, err } return nil, result + case 404: + result := NewSubscribeNotFound() + if err := result.readResponse(response, consumer, o.formats); err != nil { + return nil, err + } + return nil, result case 500: result := NewSubscribeInternalServerError() if err := result.readResponse(response, consumer, o.formats); err != nil { return nil, err } return nil, result + case 503: + result := NewSubscribeServiceUnavailable() + if err := result.readResponse(response, consumer, o.formats); err != nil { + return nil, err + } + return nil, result default: return nil, runtime.NewAPIError("unknown error", response, response.Code()) @@ -87,7 +99,7 @@ func NewSubscribeBadRequest() *SubscribeBadRequest { /*SubscribeBadRequest handles this case with default header values. -Invalid input +Not Found */ type SubscribeBadRequest struct { } @@ -101,6 +113,27 @@ func (o *SubscribeBadRequest) readResponse(response runtime.ClientResponse, cons return nil } +// NewSubscribeNotFound creates a SubscribeNotFound with default headers values +func NewSubscribeNotFound() *SubscribeNotFound { + return &SubscribeNotFound{} +} + +/*SubscribeNotFound handles this case with default header values. + +Invalid input +*/ +type SubscribeNotFound struct { +} + +func (o *SubscribeNotFound) Error() string { + return fmt.Sprintf("[POST /subscriptions][%d] subscribeNotFound ", 404) +} + +func (o *SubscribeNotFound) readResponse(response runtime.ClientResponse, consumer runtime.Consumer, formats strfmt.Registry) error { + + return nil +} + // NewSubscribeInternalServerError creates a SubscribeInternalServerError with default headers values func NewSubscribeInternalServerError() *SubscribeInternalServerError { return &SubscribeInternalServerError{} @@ -121,3 +154,24 @@ func (o *SubscribeInternalServerError) readResponse(response runtime.ClientRespo return nil } + +// NewSubscribeServiceUnavailable creates a SubscribeServiceUnavailable with default headers values +func NewSubscribeServiceUnavailable() *SubscribeServiceUnavailable { + return &SubscribeServiceUnavailable{} +} + +/*SubscribeServiceUnavailable handles this case with default header values. + +Service Unavailable +*/ +type SubscribeServiceUnavailable struct { +} + +func (o *SubscribeServiceUnavailable) Error() string { + return fmt.Sprintf("[POST /subscriptions][%d] subscribeServiceUnavailable ", 503) +} + +func (o *SubscribeServiceUnavailable) readResponse(response runtime.ClientResponse, consumer runtime.Consumer, formats strfmt.Registry) error { + + return nil +}