client

package

Go to main page

Versions in this module

v0

v0.43.0

Dec 4, 2024

v0.42.1

Dec 3, 2024

Changes in this version

+ func NewReadqueueresponseViewCreated(body *ReadResponseBody) *queueviews.ReadqueueresponseView

v0.42.0

Oct 28, 2024

v0.41.2

Jul 30, 2024

v0.41.1

Jul 17, 2024

v0.40.5

Jul 10, 2024

v0.40.3

Jul 3, 2024

v0.40.2

Jul 3, 2024

v0.40.1

Jul 1, 2024

v0.39.0

May 29, 2024

Changes in this version

+ func NewCreateNotAvailable() *queue.ServiceNotAvailableT

+ func NewDeleteNotAvailable() *queue.ServiceNotAvailableT

+ func NewListNotAvailable() *queue.ServiceNotAvailableT

+ func NewReadNotAvailable() *queue.ServiceNotAvailableT

v0.38.0

May 23, 2024

Changes in this version

+ func NewDequeueMessageListOK(body *DequeueResponseBody) *queue.MessageList

+ func NewEnqueueMessagestatusOK(body *EnqueueResponseBody) *queueviews.MessagestatusView

+ func ValidatePublishedmessageResponseBody(body *PublishedmessageResponseBody) (err error)

type DequeueResponseBody

+ Messages []*PublishedmessageResponseBody

type EnqueueResponseBody

+ ID *string

+ type PublishedmessageResponseBody struct

+ Content any

+ ContentType *string

+ ID *string

+ Schema *string

type ReadResponseBody

+ FirstID *string

+ ID *string

+ LastID *string

v0.35.3

May 10, 2024

v0.35.2

Apr 11, 2024

Changes in this version

+ func BuildCreatePayload(queueCreateBody string, queueCreateJWT string) (*queue.CreatePayload, error)

+ func BuildDeletePayload(queueDeleteID string, queueDeleteJWT string) (*queue.DeletePayload, error)

+ func BuildDequeuePayload(queueDequeueID string, queueDequeueBatch string, queueDequeueJWT string) (*queue.DequeuePayload, error)

+ func BuildEnqueuePayload(queueEnqueueBody string, queueEnqueueID string, queueEnqueueJWT string) (*queue.EnqueuePayload, error)

+ func BuildListPayload(queueListLimit string, queueListPage string, queueListFilter string, ...) (*queue.ListPayload, error)

+ func BuildReadPayload(queueReadID string, queueReadJWT string) (*queue.ReadPayload, error)

+ func CreateQueuePath() string

+ func DecodeCreateResponse(decoder func(*http.Response) goahttp.Decoder, restoreBody bool) func(*http.Response) (any, error)

+ func DecodeDeleteResponse(decoder func(*http.Response) goahttp.Decoder, restoreBody bool) func(*http.Response) (any, error)

+ func DecodeDequeueResponse(decoder func(*http.Response) goahttp.Decoder, restoreBody bool) func(*http.Response) (any, error)

+ func DecodeEnqueueResponse(decoder func(*http.Response) goahttp.Decoder, restoreBody bool) func(*http.Response) (any, error)

+ func DecodeListResponse(decoder func(*http.Response) goahttp.Decoder, restoreBody bool) func(*http.Response) (any, error)

+ func DecodeReadResponse(decoder func(*http.Response) goahttp.Decoder, restoreBody bool) func(*http.Response) (any, error)

+ func DeleteQueuePath(id string) string

+ func DequeueQueuePath(id string) string

+ func EncodeCreateRequest(encoder func(*http.Request) goahttp.Encoder) func(*http.Request, any) error

+ func EncodeDeleteRequest(encoder func(*http.Request) goahttp.Encoder) func(*http.Request, any) error

+ func EncodeDequeueRequest(encoder func(*http.Request) goahttp.Encoder) func(*http.Request, any) error

+ func EncodeEnqueueRequest(encoder func(*http.Request) goahttp.Encoder) func(*http.Request, any) error

+ func EncodeListRequest(encoder func(*http.Request) goahttp.Encoder) func(*http.Request, any) error

+ func EncodeReadRequest(encoder func(*http.Request) goahttp.Encoder) func(*http.Request, any) error

+ func EnqueueQueuePath(id string) string

+ func ListQueuePath() string

+ func NewCreateAlreadyCreated(body *CreateAlreadyCreatedResponseBody) *queue.ResourceAlreadyCreatedT

+ func NewCreateBadRequest(body *CreateBadRequestResponseBody) *queue.BadRequestT

+ func NewCreateInvalidCredential() *queue.InvalidCredentialsT

+ func NewCreateInvalidParameter(body *CreateInvalidParameterResponseBody) *queue.InvalidParameterValue

+ func NewCreateInvalidScopes(body *CreateInvalidScopesResponseBody) *queue.InvalidScopesT

+ func NewCreateNotAuthorized() *queue.UnauthorizedT

+ func NewCreateNotFound(body *CreateNotFoundResponseBody) *queue.ResourceNotFoundT

+ func NewCreateNotImplemented(body *CreateNotImplementedResponseBody) *queue.NotImplementedT

+ func NewCreatequeueresponseViewCreated(body *CreateResponseBody) *queueviews.CreatequeueresponseView

+ func NewDeleteBadRequest(body *DeleteBadRequestResponseBody) *queue.BadRequestT

+ func NewDeleteInvalidCredential() *queue.InvalidCredentialsT

+ func NewDeleteInvalidScopes(body *DeleteInvalidScopesResponseBody) *queue.InvalidScopesT

+ func NewDeleteNotAuthorized() *queue.UnauthorizedT

+ func NewDeleteNotImplemented(body *DeleteNotImplementedResponseBody) *queue.NotImplementedT

+ func NewDequeueBadRequest(body *DequeueBadRequestResponseBody) *queue.BadRequestT

+ func NewDequeueInvalidCredential() *queue.InvalidCredentialsT

+ func NewDequeueInvalidParameter(body *DequeueInvalidParameterResponseBody) *queue.InvalidParameterValue

+ func NewDequeueInvalidScopes(body *DequeueInvalidScopesResponseBody) *queue.InvalidScopesT

+ func NewDequeueMessageStatusListOK(body *DequeueResponseBody) *queue.MessageStatusList

+ func NewDequeueNotAuthorized() *queue.UnauthorizedT

+ func NewDequeueNotAvailable() *queue.ServiceNotAvailableT

+ func NewDequeueNotImplemented(body *DequeueNotImplementedResponseBody) *queue.NotImplementedT

+ func NewEnqueueBadRequest(body *EnqueueBadRequestResponseBody) *queue.BadRequestT

+ func NewEnqueueInvalidCredential() *queue.InvalidCredentialsT

+ func NewEnqueueInvalidParameter(body *EnqueueInvalidParameterResponseBody) *queue.InvalidParameterValue

+ func NewEnqueueInvalidScopes(body *EnqueueInvalidScopesResponseBody) *queue.InvalidScopesT

+ func NewEnqueueMessageStatusListOK(body *EnqueueResponseBody) *queue.MessageStatusList

+ func NewEnqueueNotAuthorized() *queue.UnauthorizedT

+ func NewEnqueueNotAvailable() *queue.ServiceNotAvailableT

+ func NewEnqueueNotImplemented(body *EnqueueNotImplementedResponseBody) *queue.NotImplementedT

+ func NewListBadRequest(body *ListBadRequestResponseBody) *queue.BadRequestT

+ func NewListInvalidCredential() *queue.InvalidCredentialsT

+ func NewListInvalidParameter(body *ListInvalidParameterResponseBody) *queue.InvalidParameterValue

+ func NewListInvalidScopes(body *ListInvalidScopesResponseBody) *queue.InvalidScopesT

+ func NewListNotAuthorized() *queue.UnauthorizedT

+ func NewListNotImplemented(body *ListNotImplementedResponseBody) *queue.NotImplementedT

+ func NewListQueueListResultOK(body *ListResponseBody) *queue.QueueListResult

+ func NewReadBadRequest(body *ReadBadRequestResponseBody) *queue.BadRequestT

+ func NewReadInvalidCredential() *queue.InvalidCredentialsT

+ func NewReadInvalidScopes(body *ReadInvalidScopesResponseBody) *queue.InvalidScopesT

+ func NewReadNotAuthorized() *queue.UnauthorizedT

+ func NewReadNotFound(body *ReadNotFoundResponseBody) *queue.ResourceNotFoundT

+ func NewReadNotImplemented(body *ReadNotImplementedResponseBody) *queue.NotImplementedT

+ func NewReadqueueresponseViewOK(body *ReadResponseBody) *queueviews.ReadqueueresponseView

+ func ReadQueuePath(id string) string

+ func ValidateCreateAlreadyCreatedResponseBody(body *CreateAlreadyCreatedResponseBody) (err error)

+ func ValidateCreateBadRequestResponseBody(body *CreateBadRequestResponseBody) (err error)

+ func ValidateCreateInvalidParameterResponseBody(body *CreateInvalidParameterResponseBody) (err error)

+ func ValidateCreateInvalidScopesResponseBody(body *CreateInvalidScopesResponseBody) (err error)

+ func ValidateCreateNotFoundResponseBody(body *CreateNotFoundResponseBody) (err error)

+ func ValidateCreateNotImplementedResponseBody(body *CreateNotImplementedResponseBody) (err error)

+ func ValidateDeleteBadRequestResponseBody(body *DeleteBadRequestResponseBody) (err error)

+ func ValidateDeleteInvalidScopesResponseBody(body *DeleteInvalidScopesResponseBody) (err error)

+ func ValidateDeleteNotImplementedResponseBody(body *DeleteNotImplementedResponseBody) (err error)

+ func ValidateDequeueBadRequestResponseBody(body *DequeueBadRequestResponseBody) (err error)

+ func ValidateDequeueInvalidParameterResponseBody(body *DequeueInvalidParameterResponseBody) (err error)

+ func ValidateDequeueInvalidScopesResponseBody(body *DequeueInvalidScopesResponseBody) (err error)

+ func ValidateDequeueNotImplementedResponseBody(body *DequeueNotImplementedResponseBody) (err error)

+ func ValidateDequeueResponseBody(body *DequeueResponseBody) (err error)

+ func ValidateEnqueueBadRequestResponseBody(body *EnqueueBadRequestResponseBody) (err error)

+ func ValidateEnqueueInvalidParameterResponseBody(body *EnqueueInvalidParameterResponseBody) (err error)

+ func ValidateEnqueueInvalidScopesResponseBody(body *EnqueueInvalidScopesResponseBody) (err error)

+ func ValidateEnqueueNotImplementedResponseBody(body *EnqueueNotImplementedResponseBody) (err error)

+ func ValidateEnqueueResponseBody(body *EnqueueResponseBody) (err error)

+ func ValidateLinkTResponseBody(body *LinkTResponseBody) (err error)

+ func ValidateListBadRequestResponseBody(body *ListBadRequestResponseBody) (err error)

+ func ValidateListInvalidParameterResponseBody(body *ListInvalidParameterResponseBody) (err error)

+ func ValidateListInvalidScopesResponseBody(body *ListInvalidScopesResponseBody) (err error)

+ func ValidateListNotImplementedResponseBody(body *ListNotImplementedResponseBody) (err error)

+ func ValidateListResponseBody(body *ListResponseBody) (err error)

+ func ValidateQueueListItemResponseBody(body *QueueListItemResponseBody) (err error)

+ func ValidateReadBadRequestResponseBody(body *ReadBadRequestResponseBody) (err error)

+ func ValidateReadInvalidScopesResponseBody(body *ReadInvalidScopesResponseBody) (err error)

+ func ValidateReadNotFoundResponseBody(body *ReadNotFoundResponseBody) (err error)

+ func ValidateReadNotImplementedResponseBody(body *ReadNotImplementedResponseBody) (err error)

+ type Client struct

+ CORSDoer goahttp.Doer

+ CreateDoer goahttp.Doer

+ DeleteDoer goahttp.Doer

+ DequeueDoer goahttp.Doer

+ EnqueueDoer goahttp.Doer

+ ListDoer goahttp.Doer

+ ReadDoer goahttp.Doer

+ RestoreResponseBody bool

+ func NewClient(scheme string, host string, doer goahttp.Doer, ...) *Client

+ func (c *Client) BuildCreateRequest(ctx context.Context, v any) (*http.Request, error)

+ func (c *Client) BuildDeleteRequest(ctx context.Context, v any) (*http.Request, error)

+ func (c *Client) BuildDequeueRequest(ctx context.Context, v any) (*http.Request, error)

+ func (c *Client) BuildEnqueueRequest(ctx context.Context, v any) (*http.Request, error)

+ func (c *Client) BuildListRequest(ctx context.Context, v any) (*http.Request, error)

+ func (c *Client) BuildReadRequest(ctx context.Context, v any) (*http.Request, error)

+ func (c *Client) Create() goa.Endpoint

+ func (c *Client) Delete() goa.Endpoint

+ func (c *Client) Dequeue() goa.Endpoint

+ func (c *Client) Enqueue() goa.Endpoint

+ func (c *Client) List() goa.Endpoint

+ func (c *Client) Read() goa.Endpoint

+ type CreateAlreadyCreatedResponseBody struct

+ ID *string

+ Message *string

+ type CreateBadRequestResponseBody struct

+ Message *string

+ type CreateInvalidParameterResponseBody struct

+ Message *string

+ Name *string

+ Value *string

+ type CreateInvalidScopesResponseBody struct

+ ID *string

+ Message *string

+ type CreateNotFoundResponseBody struct

+ ID *string

+ Message *string

+ type CreateNotImplementedResponseBody struct

+ Message *string

+ type CreateRequestBody struct

+ Description *string

+ Name string

+ Policy *string

+ func NewCreateRequestBody(p *queue.CreatePayload) *CreateRequestBody

+ type CreateResponseBody struct

+ Account *string

+ CreatedAt *string

+ Description *string

+ ID *string

+ Name *string

+ type DeleteBadRequestResponseBody struct

+ Message *string

+ type DeleteInvalidScopesResponseBody struct

+ ID *string

+ Message *string

+ type DeleteNotImplementedResponseBody struct

+ Message *string

+ type DequeueBadRequestResponseBody struct

+ Message *string

+ type DequeueInvalidParameterResponseBody struct

+ Message *string

+ Name *string

+ Value *string

+ type DequeueInvalidScopesResponseBody struct

+ ID *string

+ Message *string

+ type DequeueNotImplementedResponseBody struct

+ Message *string

+ type DequeueResponseBody struct

+ AtTime *string

+ Items []*MessagestatusResponseBody

+ type EnqueueBadRequestResponseBody struct

+ Message *string

+ type EnqueueInvalidParameterResponseBody struct

+ Message *string

+ Name *string

+ Value *string

+ type EnqueueInvalidScopesResponseBody struct

+ ID *string

+ Message *string

+ type EnqueueNotImplementedResponseBody struct

+ Message *string

+ type EnqueueResponseBody struct

+ AtTime *string

+ Items []*MessagestatusResponseBody

+ type LinkTResponseBody struct

+ Href *string

+ Rel *string

+ Type *string

+ type ListBadRequestResponseBody struct

+ Message *string

+ type ListInvalidParameterResponseBody struct

+ Message *string

+ Name *string

+ Value *string

+ type ListInvalidScopesResponseBody struct

+ ID *string

+ Message *string

+ type ListNotImplementedResponseBody struct

+ Message *string

+ type ListResponseBody struct

+ AtTime *string

+ Items []*QueueListItemResponseBody

+ Links []*LinkTResponseBody

+ type MessagestatusResponseBody struct

+ Data *QueueMessageResponseBody

+ Sequence *uint64

+ type QueueListItemResponseBody struct

+ Account *string

+ Description *string

+ Href *string

+ ID *string

+ Name *string

+ type QueueMessageRequestBodyRequestBody struct

+ Content []byte

+ ContentType *string

+ Schema *string

+ func NewQueueMessageRequestBodyRequestBody(p *queue.EnqueuePayload) []*QueueMessageRequestBodyRequestBody

+ type QueueMessageResponseBody struct

+ Content []byte

+ ContentType *string

+ Schema *string

+ type ReadBadRequestResponseBody struct

+ Message *string

+ type ReadInvalidScopesResponseBody struct

+ ID *string

+ Message *string

+ type ReadNotFoundResponseBody struct

+ ID *string

+ Message *string

+ type ReadNotImplementedResponseBody struct

+ Message *string

+ type ReadResponseBody struct

+ Bytes *uint64

+ ConsumerCount *int

+ CreatedAt *string

+ Description *string

+ FirstSeq *uint64

+ FirstTime *string

+ LastSeq *uint64

+ LastTime *string

+ Name *string

+ TotalMessages *uint64

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL