client

package
v0.43.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Dec 4, 2024 License: Apache-2.0 Imports: 13 Imported by: 2

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func BuildCreatePayload 

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

BuildCreatePayload builds the payload for the queue create endpoint from CLI flags.

func BuildDeletePayload 

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

BuildDeletePayload builds the payload for the queue delete endpoint from CLI flags.

func BuildDequeuePayload 

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

BuildDequeuePayload builds the payload for the queue dequeue endpoint from CLI flags.

func BuildEnqueuePayload 

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

BuildEnqueuePayload builds the payload for the queue enqueue endpoint from CLI flags.

func BuildListPayload 

func BuildListPayload(queueListLimit string, queueListPage string, queueListFilter string, queueListOrderBy string, queueListOrderDesc string, queueListAtTime string, queueListJWT string) (*queue.ListPayload, error)

BuildListPayload builds the payload for the queue list endpoint from CLI flags.

func BuildReadPayload 

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

BuildReadPayload builds the payload for the queue read endpoint from CLI flags.

func CreateQueuePath 

func CreateQueuePath() string

CreateQueuePath returns the URL path to the queue service create HTTP endpoint.

func DecodeCreateResponse 

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

DecodeCreateResponse returns a decoder for responses returned by the queue create endpoint. restoreBody controls whether the response body should be restored after having been read. DecodeCreateResponse may return the following errors:

  • "bad-request" (type *queue.BadRequestT): http.StatusBadRequest
  • "invalid-parameter" (type *queue.InvalidParameterT): http.StatusUnprocessableEntity
  • "invalid-scopes" (type *queue.InvalidScopesT): http.StatusForbidden
  • "not-implemented" (type *queue.NotImplementedT): http.StatusNotImplemented
  • "already-created" (type *queue.ResourceAlreadyCreatedT): http.StatusConflict
  • "not-found" (type *queue.ResourceNotFoundT): http.StatusNotFound
  • "not-available" (type *queue.ServiceNotAvailableT): http.StatusServiceUnavailable
  • "not-authorized" (type *queue.UnauthorizedT): http.StatusUnauthorized
  • error: internal error

func DecodeDeleteResponse 

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

DecodeDeleteResponse returns a decoder for responses returned by the queue delete endpoint. restoreBody controls whether the response body should be restored after having been read. DecodeDeleteResponse may return the following errors:

  • "bad-request" (type *queue.BadRequestT): http.StatusBadRequest
  • "invalid-scopes" (type *queue.InvalidScopesT): http.StatusForbidden
  • "not-implemented" (type *queue.NotImplementedT): http.StatusNotImplemented
  • "not-available" (type *queue.ServiceNotAvailableT): http.StatusServiceUnavailable
  • "not-authorized" (type *queue.UnauthorizedT): http.StatusUnauthorized
  • error: internal error

func DecodeDequeueResponse 

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

DecodeDequeueResponse returns a decoder for responses returned by the queue dequeue endpoint. restoreBody controls whether the response body should be restored after having been read. DecodeDequeueResponse may return the following errors:

  • "bad-request" (type *queue.BadRequestT): http.StatusBadRequest
  • "invalid-parameter" (type *queue.InvalidParameterT): http.StatusUnprocessableEntity
  • "invalid-scopes" (type *queue.InvalidScopesT): http.StatusForbidden
  • "not-implemented" (type *queue.NotImplementedT): http.StatusNotImplemented
  • "not-available" (type *queue.ServiceNotAvailableT): http.StatusServiceUnavailable
  • "not-authorized" (type *queue.UnauthorizedT): http.StatusUnauthorized
  • error: internal error

func DecodeEnqueueResponse 

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

DecodeEnqueueResponse returns a decoder for responses returned by the queue enqueue endpoint. restoreBody controls whether the response body should be restored after having been read. DecodeEnqueueResponse may return the following errors:

  • "bad-request" (type *queue.BadRequestT): http.StatusBadRequest
  • "invalid-parameter" (type *queue.InvalidParameterT): http.StatusUnprocessableEntity
  • "invalid-scopes" (type *queue.InvalidScopesT): http.StatusForbidden
  • "not-implemented" (type *queue.NotImplementedT): http.StatusNotImplemented
  • "not-available" (type *queue.ServiceNotAvailableT): http.StatusServiceUnavailable
  • "not-authorized" (type *queue.UnauthorizedT): http.StatusUnauthorized
  • error: internal error

func DecodeListResponse 

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

DecodeListResponse returns a decoder for responses returned by the queue list endpoint. restoreBody controls whether the response body should be restored after having been read. DecodeListResponse may return the following errors:

  • "bad-request" (type *queue.BadRequestT): http.StatusBadRequest
  • "invalid-parameter" (type *queue.InvalidParameterT): http.StatusUnprocessableEntity
  • "invalid-scopes" (type *queue.InvalidScopesT): http.StatusForbidden
  • "not-implemented" (type *queue.NotImplementedT): http.StatusNotImplemented
  • "not-available" (type *queue.ServiceNotAvailableT): http.StatusServiceUnavailable
  • "not-authorized" (type *queue.UnauthorizedT): http.StatusUnauthorized
  • error: internal error

func DecodeReadResponse 

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

DecodeReadResponse returns a decoder for responses returned by the queue read endpoint. restoreBody controls whether the response body should be restored after having been read. DecodeReadResponse may return the following errors:

  • "bad-request" (type *queue.BadRequestT): http.StatusBadRequest
  • "invalid-scopes" (type *queue.InvalidScopesT): http.StatusForbidden
  • "not-implemented" (type *queue.NotImplementedT): http.StatusNotImplemented
  • "not-found" (type *queue.ResourceNotFoundT): http.StatusNotFound
  • "not-available" (type *queue.ServiceNotAvailableT): http.StatusServiceUnavailable
  • "not-authorized" (type *queue.UnauthorizedT): http.StatusUnauthorized
  • error: internal error

func DeleteQueuePath 

func DeleteQueuePath(id string) string

DeleteQueuePath returns the URL path to the queue service delete HTTP endpoint.

func DequeueQueuePath 

func DequeueQueuePath(id string) string

DequeueQueuePath returns the URL path to the queue service dequeue HTTP endpoint.

func EncodeCreateRequest 

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

EncodeCreateRequest returns an encoder for requests sent to the queue create server.

func EncodeDeleteRequest 

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

EncodeDeleteRequest returns an encoder for requests sent to the queue delete server.

func EncodeDequeueRequest 

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

EncodeDequeueRequest returns an encoder for requests sent to the queue dequeue server.

func EncodeEnqueueRequest 

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

EncodeEnqueueRequest returns an encoder for requests sent to the queue enqueue server.

func EncodeListRequest 

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

EncodeListRequest returns an encoder for requests sent to the queue list server.

func EncodeReadRequest 

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

EncodeReadRequest returns an encoder for requests sent to the queue read server.

func EnqueueQueuePath 

func EnqueueQueuePath(id string) string

EnqueueQueuePath returns the URL path to the queue service enqueue HTTP endpoint.

func ListQueuePath 

func ListQueuePath() string

ListQueuePath returns the URL path to the queue service list HTTP endpoint.

func NewCreateAlreadyCreated 

func NewCreateAlreadyCreated(body *CreateAlreadyCreatedResponseBody) *queue.ResourceAlreadyCreatedT

NewCreateAlreadyCreated builds a queue service create endpoint already-created error.

func NewCreateBadRequest 

func NewCreateBadRequest(body *CreateBadRequestResponseBody) *queue.BadRequestT

NewCreateBadRequest builds a queue service create endpoint bad-request error.

func NewCreateInvalidParameter 

func NewCreateInvalidParameter(body *CreateInvalidParameterResponseBody) *queue.InvalidParameterT

NewCreateInvalidParameter builds a queue service create endpoint invalid-parameter error.

func NewCreateInvalidScopes 

func NewCreateInvalidScopes(body *CreateInvalidScopesResponseBody) *queue.InvalidScopesT

NewCreateInvalidScopes builds a queue service create endpoint invalid-scopes error.

func NewCreateNotAuthorized 

func NewCreateNotAuthorized() *queue.UnauthorizedT

NewCreateNotAuthorized builds a queue service create endpoint not-authorized error.

func NewCreateNotAvailable added in v0.39.0 

func NewCreateNotAvailable() *queue.ServiceNotAvailableT

NewCreateNotAvailable builds a queue service create endpoint not-available error.

func NewCreateNotFound 

func NewCreateNotFound(body *CreateNotFoundResponseBody) *queue.ResourceNotFoundT

NewCreateNotFound builds a queue service create endpoint not-found error.

func NewCreateNotImplemented 

func NewCreateNotImplemented(body *CreateNotImplementedResponseBody) *queue.NotImplementedT

NewCreateNotImplemented builds a queue service create endpoint not-implemented error.

func NewCreatequeueresponseViewCreated 

func NewCreatequeueresponseViewCreated(body *CreateResponseBody) *queueviews.CreatequeueresponseView

NewCreatequeueresponseViewCreated builds a "queue" service "create" endpoint result from a HTTP "Created" response.

func NewDeleteBadRequest 

func NewDeleteBadRequest(body *DeleteBadRequestResponseBody) *queue.BadRequestT

NewDeleteBadRequest builds a queue service delete endpoint bad-request error.

func NewDeleteInvalidScopes 

func NewDeleteInvalidScopes(body *DeleteInvalidScopesResponseBody) *queue.InvalidScopesT

NewDeleteInvalidScopes builds a queue service delete endpoint invalid-scopes error.

func NewDeleteNotAuthorized 

func NewDeleteNotAuthorized() *queue.UnauthorizedT

NewDeleteNotAuthorized builds a queue service delete endpoint not-authorized error.

func NewDeleteNotAvailable added in v0.39.0 

func NewDeleteNotAvailable() *queue.ServiceNotAvailableT

NewDeleteNotAvailable builds a queue service delete endpoint not-available error.

func NewDeleteNotImplemented 

func NewDeleteNotImplemented(body *DeleteNotImplementedResponseBody) *queue.NotImplementedT

NewDeleteNotImplemented builds a queue service delete endpoint not-implemented error.

func NewDequeueBadRequest 

func NewDequeueBadRequest(body *DequeueBadRequestResponseBody) *queue.BadRequestT

NewDequeueBadRequest builds a queue service dequeue endpoint bad-request error.

func NewDequeueInvalidParameter 

func NewDequeueInvalidParameter(body *DequeueInvalidParameterResponseBody) *queue.InvalidParameterT

NewDequeueInvalidParameter builds a queue service dequeue endpoint invalid-parameter error.

func NewDequeueInvalidScopes 

func NewDequeueInvalidScopes(body *DequeueInvalidScopesResponseBody) *queue.InvalidScopesT

NewDequeueInvalidScopes builds a queue service dequeue endpoint invalid-scopes error.

func NewDequeueMessageListOK added in v0.38.0 

func NewDequeueMessageListOK(body *DequeueResponseBody) *queue.MessageList

NewDequeueMessageListOK builds a "queue" service "dequeue" endpoint result from a HTTP "OK" response.

func NewDequeueNotAuthorized 

func NewDequeueNotAuthorized() *queue.UnauthorizedT

NewDequeueNotAuthorized builds a queue service dequeue endpoint not-authorized error.

func NewDequeueNotAvailable 

func NewDequeueNotAvailable() *queue.ServiceNotAvailableT

NewDequeueNotAvailable builds a queue service dequeue endpoint not-available error.

func NewDequeueNotImplemented 

func NewDequeueNotImplemented(body *DequeueNotImplementedResponseBody) *queue.NotImplementedT

NewDequeueNotImplemented builds a queue service dequeue endpoint not-implemented error.

func NewEnqueueBadRequest 

func NewEnqueueBadRequest(body *EnqueueBadRequestResponseBody) *queue.BadRequestT

NewEnqueueBadRequest builds a queue service enqueue endpoint bad-request error.

func NewEnqueueInvalidParameter 

func NewEnqueueInvalidParameter(body *EnqueueInvalidParameterResponseBody) *queue.InvalidParameterT

NewEnqueueInvalidParameter builds a queue service enqueue endpoint invalid-parameter error.

func NewEnqueueInvalidScopes 

func NewEnqueueInvalidScopes(body *EnqueueInvalidScopesResponseBody) *queue.InvalidScopesT

NewEnqueueInvalidScopes builds a queue service enqueue endpoint invalid-scopes error.

func NewEnqueueMessagestatusOK added in v0.38.0 

func NewEnqueueMessagestatusOK(body *EnqueueResponseBody) *queueviews.MessagestatusView

NewEnqueueMessagestatusOK builds a "queue" service "enqueue" endpoint result from a HTTP "OK" response.

func NewEnqueueNotAuthorized 

func NewEnqueueNotAuthorized() *queue.UnauthorizedT

NewEnqueueNotAuthorized builds a queue service enqueue endpoint not-authorized error.

func NewEnqueueNotAvailable 

func NewEnqueueNotAvailable() *queue.ServiceNotAvailableT

NewEnqueueNotAvailable builds a queue service enqueue endpoint not-available error.

func NewEnqueueNotImplemented 

func NewEnqueueNotImplemented(body *EnqueueNotImplementedResponseBody) *queue.NotImplementedT

NewEnqueueNotImplemented builds a queue service enqueue endpoint not-implemented error.

func NewListBadRequest 

func NewListBadRequest(body *ListBadRequestResponseBody) *queue.BadRequestT

NewListBadRequest builds a queue service list endpoint bad-request error.

func NewListInvalidParameter 

func NewListInvalidParameter(body *ListInvalidParameterResponseBody) *queue.InvalidParameterT

NewListInvalidParameter builds a queue service list endpoint invalid-parameter error.

func NewListInvalidScopes 

func NewListInvalidScopes(body *ListInvalidScopesResponseBody) *queue.InvalidScopesT

NewListInvalidScopes builds a queue service list endpoint invalid-scopes error.

func NewListNotAuthorized 

func NewListNotAuthorized() *queue.UnauthorizedT

NewListNotAuthorized builds a queue service list endpoint not-authorized error.

func NewListNotAvailable added in v0.39.0 

func NewListNotAvailable() *queue.ServiceNotAvailableT

NewListNotAvailable builds a queue service list endpoint not-available error.

func NewListNotImplemented 

func NewListNotImplemented(body *ListNotImplementedResponseBody) *queue.NotImplementedT

NewListNotImplemented builds a queue service list endpoint not-implemented error.

func NewListQueueListResultOK 

func NewListQueueListResultOK(body *ListResponseBody) *queue.QueueListResult

NewListQueueListResultOK builds a "queue" service "list" endpoint result from a HTTP "OK" response.

func NewReadBadRequest 

func NewReadBadRequest(body *ReadBadRequestResponseBody) *queue.BadRequestT

NewReadBadRequest builds a queue service read endpoint bad-request error.

func NewReadInvalidScopes 

func NewReadInvalidScopes(body *ReadInvalidScopesResponseBody) *queue.InvalidScopesT

NewReadInvalidScopes builds a queue service read endpoint invalid-scopes error.

func NewReadNotAuthorized 

func NewReadNotAuthorized() *queue.UnauthorizedT

NewReadNotAuthorized builds a queue service read endpoint not-authorized error.

func NewReadNotAvailable added in v0.39.0 

func NewReadNotAvailable() *queue.ServiceNotAvailableT

NewReadNotAvailable builds a queue service read endpoint not-available error.

func NewReadNotFound 

func NewReadNotFound(body *ReadNotFoundResponseBody) *queue.ResourceNotFoundT

NewReadNotFound builds a queue service read endpoint not-found error.

func NewReadNotImplemented 

func NewReadNotImplemented(body *ReadNotImplementedResponseBody) *queue.NotImplementedT

NewReadNotImplemented builds a queue service read endpoint not-implemented error.

func NewReadqueueresponseViewCreated added in v0.42.1 

func NewReadqueueresponseViewCreated(body *ReadResponseBody) *queueviews.ReadqueueresponseView

NewReadqueueresponseViewCreated builds a "queue" service "read" endpoint result from a HTTP "Created" response.

func ReadQueuePath 

func ReadQueuePath(id string) string

ReadQueuePath returns the URL path to the queue service read HTTP endpoint.

func ValidateCreateAlreadyCreatedResponseBody 

func ValidateCreateAlreadyCreatedResponseBody(body *CreateAlreadyCreatedResponseBody) (err error)

ValidateCreateAlreadyCreatedResponseBody runs the validations defined on create_already-created_response_body

func ValidateCreateBadRequestResponseBody 

func ValidateCreateBadRequestResponseBody(body *CreateBadRequestResponseBody) (err error)

ValidateCreateBadRequestResponseBody runs the validations defined on create_bad-request_response_body

func ValidateCreateInvalidParameterResponseBody 

func ValidateCreateInvalidParameterResponseBody(body *CreateInvalidParameterResponseBody) (err error)

ValidateCreateInvalidParameterResponseBody runs the validations defined on create_invalid-parameter_response_body

func ValidateCreateInvalidScopesResponseBody 

func ValidateCreateInvalidScopesResponseBody(body *CreateInvalidScopesResponseBody) (err error)

ValidateCreateInvalidScopesResponseBody runs the validations defined on create_invalid-scopes_response_body

func ValidateCreateNotFoundResponseBody 

func ValidateCreateNotFoundResponseBody(body *CreateNotFoundResponseBody) (err error)

ValidateCreateNotFoundResponseBody runs the validations defined on create_not-found_response_body

func ValidateCreateNotImplementedResponseBody 

func ValidateCreateNotImplementedResponseBody(body *CreateNotImplementedResponseBody) (err error)

ValidateCreateNotImplementedResponseBody runs the validations defined on create_not-implemented_response_body

func ValidateDeleteBadRequestResponseBody 

func ValidateDeleteBadRequestResponseBody(body *DeleteBadRequestResponseBody) (err error)

ValidateDeleteBadRequestResponseBody runs the validations defined on delete_bad-request_response_body

func ValidateDeleteInvalidScopesResponseBody 

func ValidateDeleteInvalidScopesResponseBody(body *DeleteInvalidScopesResponseBody) (err error)

ValidateDeleteInvalidScopesResponseBody runs the validations defined on delete_invalid-scopes_response_body

func ValidateDeleteNotImplementedResponseBody 

func ValidateDeleteNotImplementedResponseBody(body *DeleteNotImplementedResponseBody) (err error)

ValidateDeleteNotImplementedResponseBody runs the validations defined on delete_not-implemented_response_body

func ValidateDequeueBadRequestResponseBody 

func ValidateDequeueBadRequestResponseBody(body *DequeueBadRequestResponseBody) (err error)

ValidateDequeueBadRequestResponseBody runs the validations defined on dequeue_bad-request_response_body

func ValidateDequeueInvalidParameterResponseBody 

func ValidateDequeueInvalidParameterResponseBody(body *DequeueInvalidParameterResponseBody) (err error)

ValidateDequeueInvalidParameterResponseBody runs the validations defined on dequeue_invalid-parameter_response_body

func ValidateDequeueInvalidScopesResponseBody 

func ValidateDequeueInvalidScopesResponseBody(body *DequeueInvalidScopesResponseBody) (err error)

ValidateDequeueInvalidScopesResponseBody runs the validations defined on dequeue_invalid-scopes_response_body

func ValidateDequeueNotImplementedResponseBody 

func ValidateDequeueNotImplementedResponseBody(body *DequeueNotImplementedResponseBody) (err error)

ValidateDequeueNotImplementedResponseBody runs the validations defined on dequeue_not-implemented_response_body

func ValidateDequeueResponseBody 

func ValidateDequeueResponseBody(body *DequeueResponseBody) (err error)

ValidateDequeueResponseBody runs the validations defined on DequeueResponseBody

func ValidateEnqueueBadRequestResponseBody 

func ValidateEnqueueBadRequestResponseBody(body *EnqueueBadRequestResponseBody) (err error)

ValidateEnqueueBadRequestResponseBody runs the validations defined on enqueue_bad-request_response_body

func ValidateEnqueueInvalidParameterResponseBody 

func ValidateEnqueueInvalidParameterResponseBody(body *EnqueueInvalidParameterResponseBody) (err error)

ValidateEnqueueInvalidParameterResponseBody runs the validations defined on enqueue_invalid-parameter_response_body

func ValidateEnqueueInvalidScopesResponseBody 

func ValidateEnqueueInvalidScopesResponseBody(body *EnqueueInvalidScopesResponseBody) (err error)

ValidateEnqueueInvalidScopesResponseBody runs the validations defined on enqueue_invalid-scopes_response_body

func ValidateEnqueueNotImplementedResponseBody 

func ValidateEnqueueNotImplementedResponseBody(body *EnqueueNotImplementedResponseBody) (err error)

ValidateEnqueueNotImplementedResponseBody runs the validations defined on enqueue_not-implemented_response_body

func ValidateLinkTResponseBody 

func ValidateLinkTResponseBody(body *LinkTResponseBody) (err error)

ValidateLinkTResponseBody runs the validations defined on LinkTResponseBody

func ValidateListBadRequestResponseBody 

func ValidateListBadRequestResponseBody(body *ListBadRequestResponseBody) (err error)

ValidateListBadRequestResponseBody runs the validations defined on list_bad-request_response_body

func ValidateListInvalidParameterResponseBody 

func ValidateListInvalidParameterResponseBody(body *ListInvalidParameterResponseBody) (err error)

ValidateListInvalidParameterResponseBody runs the validations defined on list_invalid-parameter_response_body

func ValidateListInvalidScopesResponseBody 

func ValidateListInvalidScopesResponseBody(body *ListInvalidScopesResponseBody) (err error)

ValidateListInvalidScopesResponseBody runs the validations defined on list_invalid-scopes_response_body

func ValidateListNotImplementedResponseBody 

func ValidateListNotImplementedResponseBody(body *ListNotImplementedResponseBody) (err error)

ValidateListNotImplementedResponseBody runs the validations defined on list_not-implemented_response_body

func ValidateListResponseBody 

func ValidateListResponseBody(body *ListResponseBody) (err error)

ValidateListResponseBody runs the validations defined on ListResponseBody

func ValidatePublishedmessageResponseBody added in v0.38.0 

func ValidatePublishedmessageResponseBody(body *PublishedmessageResponseBody) (err error)

ValidatePublishedmessageResponseBody runs the validations defined on PublishedmessageResponseBody

func ValidateQueueListItemResponseBody 

func ValidateQueueListItemResponseBody(body *QueueListItemResponseBody) (err error)

ValidateQueueListItemResponseBody runs the validations defined on QueueListItemResponseBody

func ValidateReadBadRequestResponseBody 

func ValidateReadBadRequestResponseBody(body *ReadBadRequestResponseBody) (err error)

ValidateReadBadRequestResponseBody runs the validations defined on read_bad-request_response_body

func ValidateReadInvalidScopesResponseBody 

func ValidateReadInvalidScopesResponseBody(body *ReadInvalidScopesResponseBody) (err error)

ValidateReadInvalidScopesResponseBody runs the validations defined on read_invalid-scopes_response_body

func ValidateReadNotFoundResponseBody 

func ValidateReadNotFoundResponseBody(body *ReadNotFoundResponseBody) (err error)

ValidateReadNotFoundResponseBody runs the validations defined on read_not-found_response_body

func ValidateReadNotImplementedResponseBody 

func ValidateReadNotImplementedResponseBody(body *ReadNotImplementedResponseBody) (err error)

ValidateReadNotImplementedResponseBody runs the validations defined on read_not-implemented_response_body

Types

type Client 

type Client struct {
	// Create Doer is the HTTP client used to make requests to the create endpoint.
	CreateDoer goahttp.Doer

	// Read Doer is the HTTP client used to make requests to the read endpoint.
	ReadDoer goahttp.Doer

	// Delete Doer is the HTTP client used to make requests to the delete endpoint.
	DeleteDoer goahttp.Doer

	// List Doer is the HTTP client used to make requests to the list endpoint.
	ListDoer goahttp.Doer

	// Enqueue Doer is the HTTP client used to make requests to the enqueue
	// endpoint.
	EnqueueDoer goahttp.Doer

	// Dequeue Doer is the HTTP client used to make requests to the dequeue
	// endpoint.
	DequeueDoer goahttp.Doer

	// CORS Doer is the HTTP client used to make requests to the  endpoint.
	CORSDoer goahttp.Doer

	// RestoreResponseBody controls whether the response bodies are reset after
	// decoding so they can be read again.
	RestoreResponseBody bool
	// contains filtered or unexported fields
}

Client lists the queue service endpoint HTTP clients.

func NewClient 

func NewClient(
	scheme string,
	host string,
	doer goahttp.Doer,
	enc func(*http.Request) goahttp.Encoder,
	dec func(*http.Response) goahttp.Decoder,
	restoreBody bool,
) *Client

NewClient instantiates HTTP clients for all the queue service servers.

func (*Client) BuildCreateRequest 

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

BuildCreateRequest instantiates a HTTP request object with method and path set to call the "queue" service "create" endpoint

func (*Client) BuildDeleteRequest 

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

BuildDeleteRequest instantiates a HTTP request object with method and path set to call the "queue" service "delete" endpoint

func (*Client) BuildDequeueRequest 

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

BuildDequeueRequest instantiates a HTTP request object with method and path set to call the "queue" service "dequeue" endpoint

func (*Client) BuildEnqueueRequest 

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

BuildEnqueueRequest instantiates a HTTP request object with method and path set to call the "queue" service "enqueue" endpoint

func (*Client) BuildListRequest 

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

BuildListRequest instantiates a HTTP request object with method and path set to call the "queue" service "list" endpoint

func (*Client) BuildReadRequest 

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

BuildReadRequest instantiates a HTTP request object with method and path set to call the "queue" service "read" endpoint

func (*Client) Create 

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

Create returns an endpoint that makes HTTP requests to the queue service create server.

func (*Client) Delete 

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

Delete returns an endpoint that makes HTTP requests to the queue service delete server.

func (*Client) Dequeue 

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

Dequeue returns an endpoint that makes HTTP requests to the queue service dequeue server.

func (*Client) Enqueue 

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

Enqueue returns an endpoint that makes HTTP requests to the queue service enqueue server.

func (*Client) List 

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

List returns an endpoint that makes HTTP requests to the queue service list server.

func (*Client) Read 

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

Read returns an endpoint that makes HTTP requests to the queue service read server.

type CreateAlreadyCreatedResponseBody 

type CreateAlreadyCreatedResponseBody struct {
	// ID of already existing resource
	ID *string `form:"id,omitempty" json:"id,omitempty" xml:"id,omitempty"`
	// Message of error
	Message *string `form:"message,omitempty" json:"message,omitempty" xml:"message,omitempty"`
}

CreateAlreadyCreatedResponseBody is the type of the "queue" service "create" endpoint HTTP response body for the "already-created" error.

type CreateBadRequestResponseBody 

type CreateBadRequestResponseBody struct {
	// Information message
	Message *string `form:"message,omitempty" json:"message,omitempty" xml:"message,omitempty"`
}

CreateBadRequestResponseBody is the type of the "queue" service "create" endpoint HTTP response body for the "bad-request" error.

type CreateInvalidParameterResponseBody 

type CreateInvalidParameterResponseBody struct {
	// message describing expected type or pattern.
	Message *string `form:"message,omitempty" json:"message,omitempty" xml:"message,omitempty"`
	// name of parameter.
	Name *string `form:"name,omitempty" json:"name,omitempty" xml:"name,omitempty"`
	// provided parameter value.
	Value *string `form:"value,omitempty" json:"value,omitempty" xml:"value,omitempty"`
}

CreateInvalidParameterResponseBody is the type of the "queue" service "create" endpoint HTTP response body for the "invalid-parameter" error.

type CreateInvalidScopesResponseBody 

type CreateInvalidScopesResponseBody struct {
	// ID of involved resource
	ID *string `form:"id,omitempty" json:"id,omitempty" xml:"id,omitempty"`
	// Message of error
	Message *string `form:"message,omitempty" json:"message,omitempty" xml:"message,omitempty"`
}

CreateInvalidScopesResponseBody is the type of the "queue" service "create" endpoint HTTP response body for the "invalid-scopes" error.

type CreateNotFoundResponseBody 

type CreateNotFoundResponseBody struct {
	// ID of missing resource
	ID *string `form:"id,omitempty" json:"id,omitempty" xml:"id,omitempty"`
	// Message of error
	Message *string `form:"message,omitempty" json:"message,omitempty" xml:"message,omitempty"`
}

CreateNotFoundResponseBody is the type of the "queue" service "create" endpoint HTTP response body for the "not-found" error.

type CreateNotImplementedResponseBody 

type CreateNotImplementedResponseBody struct {
	// Information message
	Message *string `form:"message,omitempty" json:"message,omitempty" xml:"message,omitempty"`
}

CreateNotImplementedResponseBody is the type of the "queue" service "create" endpoint HTTP response body for the "not-implemented" error.

type CreateRequestBody 

type CreateRequestBody struct {
	// Optional Name for the queue. Cannot contain whitespace, ., *, >, path
	// separators (forward or backwards slash), and non-printable characters.
	Name string `form:"name" json:"name" xml:"name"`
	// More detailed description of the queue.
	Description *string `form:"description,omitempty" json:"description,omitempty" xml:"description,omitempty"`
	// Reference to policy used
	Policy *string `form:"policy,omitempty" json:"policy,omitempty" xml:"policy,omitempty"`
}

CreateRequestBody is the type of the "queue" service "create" endpoint HTTP request body.

func NewCreateRequestBody 

func NewCreateRequestBody(p *queue.CreatePayload) *CreateRequestBody

NewCreateRequestBody builds the HTTP request body from the payload of the "create" endpoint of the "queue" service.

type CreateResponseBody 

type CreateResponseBody struct {
	// queue
	ID *string `form:"id,omitempty" json:"id,omitempty" xml:"id,omitempty"`
	// Name of the created queue.
	Name *string `form:"name,omitempty" json:"name,omitempty" xml:"name,omitempty"`
	// Description of the created queue.
	Description *string `form:"description,omitempty" json:"description,omitempty" xml:"description,omitempty"`
	// Timestamp when the queue was created
	CreatedAt *string `form:"created-at,omitempty" json:"created-at,omitempty" xml:"created-at,omitempty"`
	// Reference to billable account
	Account *string `form:"account,omitempty" json:"account,omitempty" xml:"account,omitempty"`
}

CreateResponseBody is the type of the "queue" service "create" endpoint HTTP response body.

type DeleteBadRequestResponseBody 

type DeleteBadRequestResponseBody struct {
	// Information message
	Message *string `form:"message,omitempty" json:"message,omitempty" xml:"message,omitempty"`
}

DeleteBadRequestResponseBody is the type of the "queue" service "delete" endpoint HTTP response body for the "bad-request" error.

type DeleteInvalidScopesResponseBody 

type DeleteInvalidScopesResponseBody struct {
	// ID of involved resource
	ID *string `form:"id,omitempty" json:"id,omitempty" xml:"id,omitempty"`
	// Message of error
	Message *string `form:"message,omitempty" json:"message,omitempty" xml:"message,omitempty"`
}

DeleteInvalidScopesResponseBody is the type of the "queue" service "delete" endpoint HTTP response body for the "invalid-scopes" error.

type DeleteNotImplementedResponseBody 

type DeleteNotImplementedResponseBody struct {
	// Information message
	Message *string `form:"message,omitempty" json:"message,omitempty" xml:"message,omitempty"`
}

DeleteNotImplementedResponseBody is the type of the "queue" service "delete" endpoint HTTP response body for the "not-implemented" error.

type DequeueBadRequestResponseBody 

type DequeueBadRequestResponseBody struct {
	// Information message
	Message *string `form:"message,omitempty" json:"message,omitempty" xml:"message,omitempty"`
}

DequeueBadRequestResponseBody is the type of the "queue" service "dequeue" endpoint HTTP response body for the "bad-request" error.

type DequeueInvalidParameterResponseBody 

type DequeueInvalidParameterResponseBody struct {
	// message describing expected type or pattern.
	Message *string `form:"message,omitempty" json:"message,omitempty" xml:"message,omitempty"`
	// name of parameter.
	Name *string `form:"name,omitempty" json:"name,omitempty" xml:"name,omitempty"`
	// provided parameter value.
	Value *string `form:"value,omitempty" json:"value,omitempty" xml:"value,omitempty"`
}

DequeueInvalidParameterResponseBody is the type of the "queue" service "dequeue" endpoint HTTP response body for the "invalid-parameter" error.

type DequeueInvalidScopesResponseBody 

type DequeueInvalidScopesResponseBody struct {
	// ID of involved resource
	ID *string `form:"id,omitempty" json:"id,omitempty" xml:"id,omitempty"`
	// Message of error
	Message *string `form:"message,omitempty" json:"message,omitempty" xml:"message,omitempty"`
}

DequeueInvalidScopesResponseBody is the type of the "queue" service "dequeue" endpoint HTTP response body for the "invalid-scopes" error.

type DequeueNotImplementedResponseBody 

type DequeueNotImplementedResponseBody struct {
	// Information message
	Message *string `form:"message,omitempty" json:"message,omitempty" xml:"message,omitempty"`
}

DequeueNotImplementedResponseBody is the type of the "queue" service "dequeue" endpoint HTTP response body for the "not-implemented" error.

type DequeueResponseBody 

type DequeueResponseBody struct {
	// Messages in the queue
	Messages []*PublishedmessageResponseBody `form:"messages,omitempty" json:"messages,omitempty" xml:"messages,omitempty"`
	// Time at which this list was valid
	AtTime *string `form:"at-time,omitempty" json:"at-time,omitempty" xml:"at-time,omitempty"`
}

DequeueResponseBody is the type of the "queue" service "dequeue" endpoint HTTP response body.

type EnqueueBadRequestResponseBody 

type EnqueueBadRequestResponseBody struct {
	// Information message
	Message *string `form:"message,omitempty" json:"message,omitempty" xml:"message,omitempty"`
}

EnqueueBadRequestResponseBody is the type of the "queue" service "enqueue" endpoint HTTP response body for the "bad-request" error.

type EnqueueInvalidParameterResponseBody 

type EnqueueInvalidParameterResponseBody struct {
	// message describing expected type or pattern.
	Message *string `form:"message,omitempty" json:"message,omitempty" xml:"message,omitempty"`
	// name of parameter.
	Name *string `form:"name,omitempty" json:"name,omitempty" xml:"name,omitempty"`
	// provided parameter value.
	Value *string `form:"value,omitempty" json:"value,omitempty" xml:"value,omitempty"`
}

EnqueueInvalidParameterResponseBody is the type of the "queue" service "enqueue" endpoint HTTP response body for the "invalid-parameter" error.

type EnqueueInvalidScopesResponseBody 

type EnqueueInvalidScopesResponseBody struct {
	// ID of involved resource
	ID *string `form:"id,omitempty" json:"id,omitempty" xml:"id,omitempty"`
	// Message of error
	Message *string `form:"message,omitempty" json:"message,omitempty" xml:"message,omitempty"`
}

EnqueueInvalidScopesResponseBody is the type of the "queue" service "enqueue" endpoint HTTP response body for the "invalid-scopes" error.

type EnqueueNotImplementedResponseBody 

type EnqueueNotImplementedResponseBody struct {
	// Information message
	Message *string `form:"message,omitempty" json:"message,omitempty" xml:"message,omitempty"`
}

EnqueueNotImplementedResponseBody is the type of the "queue" service "enqueue" endpoint HTTP response body for the "not-implemented" error.

type EnqueueResponseBody 

type EnqueueResponseBody struct {
	// queue
	ID *string `form:"id,omitempty" json:"id,omitempty" xml:"id,omitempty"`
}

EnqueueResponseBody is the type of the "queue" service "enqueue" endpoint HTTP response body.

type LinkTResponseBody 

type LinkTResponseBody struct {
	// relation type
	Rel *string `form:"rel,omitempty" json:"rel,omitempty" xml:"rel,omitempty"`
	// mime type
	Type *string `form:"type,omitempty" json:"type,omitempty" xml:"type,omitempty"`
	// web link
	Href *string `form:"href,omitempty" json:"href,omitempty" xml:"href,omitempty"`
}

LinkTResponseBody is used to define fields on response body types.

type ListBadRequestResponseBody 

type ListBadRequestResponseBody struct {
	// Information message
	Message *string `form:"message,omitempty" json:"message,omitempty" xml:"message,omitempty"`
}

ListBadRequestResponseBody is the type of the "queue" service "list" endpoint HTTP response body for the "bad-request" error.

type ListInvalidParameterResponseBody 

type ListInvalidParameterResponseBody struct {
	// message describing expected type or pattern.
	Message *string `form:"message,omitempty" json:"message,omitempty" xml:"message,omitempty"`
	// name of parameter.
	Name *string `form:"name,omitempty" json:"name,omitempty" xml:"name,omitempty"`
	// provided parameter value.
	Value *string `form:"value,omitempty" json:"value,omitempty" xml:"value,omitempty"`
}

ListInvalidParameterResponseBody is the type of the "queue" service "list" endpoint HTTP response body for the "invalid-parameter" error.

type ListInvalidScopesResponseBody 

type ListInvalidScopesResponseBody struct {
	// ID of involved resource
	ID *string `form:"id,omitempty" json:"id,omitempty" xml:"id,omitempty"`
	// Message of error
	Message *string `form:"message,omitempty" json:"message,omitempty" xml:"message,omitempty"`
}

ListInvalidScopesResponseBody is the type of the "queue" service "list" endpoint HTTP response body for the "invalid-scopes" error.

type ListNotImplementedResponseBody 

type ListNotImplementedResponseBody struct {
	// Information message
	Message *string `form:"message,omitempty" json:"message,omitempty" xml:"message,omitempty"`
}

ListNotImplementedResponseBody is the type of the "queue" service "list" endpoint HTTP response body for the "not-implemented" error.

type ListResponseBody 

type ListResponseBody struct {
	// Queues
	Items []*QueueListItemResponseBody `form:"items,omitempty" json:"items,omitempty" xml:"items,omitempty"`
	// Time at which this list was valid
	AtTime *string              `form:"at-time,omitempty" json:"at-time,omitempty" xml:"at-time,omitempty"`
	Links  []*LinkTResponseBody `form:"links,omitempty" json:"links,omitempty" xml:"links,omitempty"`
}

ListResponseBody is the type of the "queue" service "list" endpoint HTTP response body.

type PublishedmessageResponseBody added in v0.38.0 

type PublishedmessageResponseBody struct {
	// Message identifier
	ID *string `form:"id,omitempty" json:"id,omitempty" xml:"id,omitempty"`
	// Message content in JSON format.
	Content any `form:"content,omitempty" json:"content,omitempty" xml:"content,omitempty"`
	// Schema used for message
	Schema *string `form:"schema,omitempty" json:"schema,omitempty" xml:"schema,omitempty"`
	// Encoding type of message content (defaults to 'application/json')
	ContentType *string `form:"content-type,omitempty" json:"content-type,omitempty" xml:"content-type,omitempty"`
}

PublishedmessageResponseBody is used to define fields on response body types.

type QueueListItemResponseBody 

type QueueListItemResponseBody struct {
	// queue
	ID *string `form:"id,omitempty" json:"id,omitempty" xml:"id,omitempty"`
	// Name of the created queue.
	Name *string `form:"name,omitempty" json:"name,omitempty" xml:"name,omitempty"`
	// Description of the created queue.
	Description *string `form:"description,omitempty" json:"description,omitempty" xml:"description,omitempty"`
	// Reference to billable account
	Account *string `form:"account,omitempty" json:"account,omitempty" xml:"account,omitempty"`
	Href    *string `form:"href,omitempty" json:"href,omitempty" xml:"href,omitempty"`
}

QueueListItemResponseBody is used to define fields on response body types.

type ReadBadRequestResponseBody 

type ReadBadRequestResponseBody struct {
	// Information message
	Message *string `form:"message,omitempty" json:"message,omitempty" xml:"message,omitempty"`
}

ReadBadRequestResponseBody is the type of the "queue" service "read" endpoint HTTP response body for the "bad-request" error.

type ReadInvalidScopesResponseBody 

type ReadInvalidScopesResponseBody struct {
	// ID of involved resource
	ID *string `form:"id,omitempty" json:"id,omitempty" xml:"id,omitempty"`
	// Message of error
	Message *string `form:"message,omitempty" json:"message,omitempty" xml:"message,omitempty"`
}

ReadInvalidScopesResponseBody is the type of the "queue" service "read" endpoint HTTP response body for the "invalid-scopes" error.

type ReadNotFoundResponseBody 

type ReadNotFoundResponseBody struct {
	// ID of missing resource
	ID *string `form:"id,omitempty" json:"id,omitempty" xml:"id,omitempty"`
	// Message of error
	Message *string `form:"message,omitempty" json:"message,omitempty" xml:"message,omitempty"`
}

ReadNotFoundResponseBody is the type of the "queue" service "read" endpoint HTTP response body for the "not-found" error.

type ReadNotImplementedResponseBody 

type ReadNotImplementedResponseBody struct {
	// Information message
	Message *string `form:"message,omitempty" json:"message,omitempty" xml:"message,omitempty"`
}

ReadNotImplementedResponseBody is the type of the "queue" service "read" endpoint HTTP response body for the "not-implemented" error.

type ReadResponseBody 

type ReadResponseBody struct {
	// ID
	ID *string `form:"id,omitempty" json:"id,omitempty" xml:"id,omitempty"`
	// Name of the queue.
	Name *string `form:"name,omitempty" json:"name,omitempty" xml:"name,omitempty"`
	// Description of the queue.
	Description *string `form:"description,omitempty" json:"description,omitempty" xml:"description,omitempty"`
	// Number of messages sent to the queue
	TotalMessages *uint64 `form:"total-messages,omitempty" json:"total-messages,omitempty" xml:"total-messages,omitempty"`
	// Number of bytes in the queue
	Bytes *uint64 `form:"bytes,omitempty" json:"bytes,omitempty" xml:"bytes,omitempty"`
	// First identifier in the queue
	FirstID *string `form:"first-id,omitempty" json:"first-id,omitempty" xml:"first-id,omitempty"`
	// Timestamp of the first message in the queue
	FirstTime *string `form:"first-time,omitempty" json:"first-time,omitempty" xml:"first-time,omitempty"`
	// Last identifier in the queue
	LastID *string `form:"last-id,omitempty" json:"last-id,omitempty" xml:"last-id,omitempty"`
	// Timestamp of the last message in the queue
	LastTime *string `form:"last-time,omitempty" json:"last-time,omitempty" xml:"last-time,omitempty"`
	// Number of consumers
	ConsumerCount *int `form:"consumer-count,omitempty" json:"consumer-count,omitempty" xml:"consumer-count,omitempty"`
	// Timestamp when the queue was created
	CreatedAt *string `form:"created-at,omitempty" json:"created-at,omitempty" xml:"created-at,omitempty"`
}

ReadResponseBody is the type of the "queue" service "read" endpoint HTTP response body.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.