queue

type Auther interface {
	// JWTAuth implements the authorization logic for the JWT security scheme.
	JWTAuth(ctx context.Context, token string, schema *security.JWTScheme) (context.Context, error)
}

type BadRequestT struct {
	// Information message
	Message string
}

type CreatePayload struct {
	// New queues description
	Queues *PayloadForCreateEndpoint
	// JWT used for authentication
	JWT string
}

type Createqueueresponse struct {
	// queue
	ID string
	// Name of the created queue.
	Name string
	// Description of the created queue.
	Description *string
	// Reference to billable account
	Account *string
}

type DeletePayload struct {
	// ID of queues to update
	ID string
	// JWT used for authentication
	JWT string
}

type DequeuePayload struct {
	// queue
	ID string
	// Maximum number of messages to dequeue
	Limit *int
	// JWT used for authentication
	JWT string
}

type Endpoints struct {
	Create  goa.Endpoint
	Read    goa.Endpoint
	Delete  goa.Endpoint
	List    goa.Endpoint
	Enqueue goa.Endpoint
	Dequeue goa.Endpoint
}

type EnqueuePayload struct {
	// queue
	ID string
	// Content-Type header, MUST be of application/json.
	ContentType *string `json:"content-type,omitempty"`
	// Schema used for message
	Schema *string
	// Message content
	Content any `json:"content,omitempty"`
	// JWT used for authentication
	JWT string
}

type InvalidParameterT struct {
	// message describing expected type or pattern.
	Message string
	// name of parameter.
	Name string
	// provided parameter value.
	Value *string
}

type InvalidScopesT struct {
	// ID of involved resource
	ID *string
	// Message of error
	Message string
}

type LinkT struct {
	// relation type
	Rel string
	// mime type
	Type string
	// web link
	Href string
}

type ListPayload struct {
	// The 'limit' query option sets the maximum number of items
	// to be included in the result.
	Limit int
	// The 'filter' system query option allows clients to filter a collection of
	// resources that are addressed by a request URL. The expression specified with
	// 'filter'
	// is evaluated for each resource in the collection, and only items where the
	// expression
	// evaluates to true are included in the response.
	Filter *string
	// The 'orderby' query option allows clients to request resources in either
	// ascending order using asc or descending order using desc. If asc or desc not
	// specified,
	// then the resources will be ordered in ascending order. The request below
	// orders Trips on
	// property EndsAt in descending order.
	OrderBy *string
	// When set order result in descending order. Ascending order is the lt.
	OrderDesc bool
	// Return the state of the respective resources at that time [now]
	AtTime *string
	// The content of 'page' is returned in the 'links' part of a previous query and
	// will when set, ALL other parameters, except for 'limit' are ignored.
	Page *string
	// JWT used for authentication
	JWT string
}

type MessageList struct {
	// Messages in the queue
	Messages []*Publishedmessage
	// Time at which this list was valid
	AtTime *string
}

type Messagestatus struct {
	// queue
	ID *string
}

type NotImplementedT struct {
	// Information message
	Message string
}

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

type Publishedmessage struct {
	// Message identifier
	ID *string
	// Message content in JSON format.
	Content any
	// Schema used for message
	Schema *string
	// Encoding type of message content (defaults to 'application/json')
	ContentType *string
}

type QueueListItem struct {
	// queue
	ID string
	// Name of the created queue.
	Name *string
	// Description of the created queue.
	Description *string
	// Reference to billable account
	Account string
	Href    string
}

type QueueListResult struct {
	// Queues
	Items []*QueueListItem
	// Time at which this list was valid
	AtTime string
	Links  []*LinkT
}

type ReadPayload struct {
	// ID of queues to show
	ID string
	// JWT used for authentication
	JWT string
}

type Readqueueresponse struct {
	// ID
	ID string
	// Name of the queue.
	Name string
	// Description of the queue.
	Description *string
	// Number of messages sent to the queue
	TotalMessages *uint64
	// Number of bytes in the queue
	Bytes *uint64
	// Timestamp of the first message in the queue
	FirstTime *string
	// Timestamp of the last message in the queue
	LastTime *string
	// Number of consumers
	ConsumerCount *int
	// Timestamp when the queue was created
	CreatedAt string
}

type ResourceAlreadyCreatedT struct {
	// ID of already existing resource
	ID string
	// Message of error
	Message string
}

type ResourceNotFoundT struct {
	// ID of missing resource
	ID string
	// Message of error
	Message string
}

type Service interface {
	// Create a new queues and return its status.
	Create(context.Context, *CreatePayload) (res *Createqueueresponse, err error)
	// Show queues by ID
	Read(context.Context, *ReadPayload) (res *Readqueueresponse, err error)
	// Delete an existing queues.
	Delete(context.Context, *DeletePayload) (err error)
	// list queues
	List(context.Context, *ListPayload) (res *QueueListResult, err error)
	// Send a message to a specific queues.
	Enqueue(context.Context, *EnqueuePayload) (res *Messagestatus, err error)
	// Read a message from a specific queues.
	Dequeue(context.Context, *DequeuePayload) (res *MessageList, err error)
}

type ServiceNotAvailableT struct {
}

type UnauthorizedT struct {
}