http

type AckInput struct {
	QueueName string `path:"queue_name" maxLength:"1024" example:"user_indexing_queue" doc:"Name of the queue"`
	ID        uint64 `path:"id" example:"123" doc:"ID of the message"`
}

type AckOutput struct {
	Status int
	Body   AckOutputBody
}

type AckOutputBody struct {
	Status string `json:"status" example:"ACKNOWLEDGED" doc:"Status of the dequeue operation"`
	ID     uint64 `json:"id" doc:"ID of the message"`
}

type CreateQueueInput struct {
	Body CreateQueueInputBody
}

type CreateQueueInputBody struct {
	Name string `json:"name" maxLength:"1024" example:"user_indexing_queue" doc:"Name of the queue"`
	Type string `json:"type" enum:"delayed,fair" example:"delayed" doc:"Type of the queue"`
}

type CreateQueueOutput struct {
	Status int
	Body   CreateQueueOutputBody
}

type CreateQueueOutputBody struct {
	Status string `json:"status" example:"CREATED" doc:"Status of the create operation"`
	Name   string `json:"name" maxLength:"1024" example:"user_indexing_queue" doc:"Name of the queue"`
	Type   string `json:"type" enum:"delayed,fair" example:"delayed" doc:"Type of the queue"`
}

type DeleteQueueInput struct {
	QueueName string `path:"queue_name" maxLength:"1024" example:"user_indexing_queue" doc:"Name of the queue"`
}

type DeleteQueueOutput struct {
	Status int
	Body   DeleteQueueOutputBody
}

type DeleteQueueOutputBody struct {
	Status string `json:"status" example:"DELETED" doc:"Status of the delete operation"`
}

type DequeueInput struct {
	QueueName string `path:"queue_name" maxLength:"1024" example:"user_indexing_queue" doc:"Name of the queue"`
	Ack       bool   `query:"ack" example:"true" doc:"Acknowledge the message"`
}

type DequeueOutput struct {
	Status int
	Body   DequeueOutputBody
}

type DequeueOutputBody struct {
	Status   string `json:"status" example:"DEQUEUED" doc:"Status of the dequeue operation"`
	ID       uint64 `json:"id" doc:"ID of the message"`
	Group    string `json:"group,omitempty" default:"default" example:"customer-1" doc:"Group of the message"`
	Priority int64  `json:"priority" minimum:"0" example:"60" doc:"Priority of the message"`
	Content  string `json:"content" example:"{\"user_id\": 1}" doc:"Content of the message"`
}

type EnqueueInput struct {
	QueueName string `path:"queue_name" maxLength:"1024" example:"user_indexing_queue" doc:"Name of the queue"`
	Body      EnqueueInputBody
}

type EnqueueInputBody struct {
	Group    string `json:"group,omitempty" default:"default" example:"customer-1" doc:"Group of the message"`
	Priority int64  `json:"priority" minimum:"0" example:"60" doc:"Priority of the message"`
	Content  string `json:"content" example:"{\"user_id\": 1}" doc:"Content of the message"`
}

type EnqueueOutput struct {
	Status int
	Body   EnqueueOutputBody
}

type EnqueueOutputBody struct {
	Status   string `json:"status" example:"ENQUEUED" doc:"Status of the enqueue operation"`
	ID       uint64 `json:"id" doc:"ID of the message"`
	Group    string `json:"group,omitempty" default:"default" example:"customer-1" doc:"Group of the message"`
	Priority int64  `json:"priority" minimum:"0" example:"60" doc:"Priority of the message"`
	Content  string `json:"content" example:"{\"user_id\": 1}" doc:"Content of the message"`
}

type Handler struct {
	// contains filtered or unexported fields
}

type JoinInput struct {
	Body struct {
		ID   string `json:"id" example:"node-0" doc:"ID of a node"`
		Addr string `json:"addr" example:"localhost:12001" doc:"IP address and a port of a service"`
	}
}

type JoinOutput struct {
	Body struct {
		ID   string `json:"id" example:"node-0" doc:"ID of a node"`
		Addr string `json:"addr" example:"localhost:12001" doc:"IP address and a port of a service"`
	}
}

type Node interface {
	Join(nodeID string, addr string) error
	Leader() string
	IsLeader() bool
	GenerateID() uint64
	CreateQueue(queueType, queueName string) error
	DeleteQueue(queueName string) error
	Enqueue(queueName string, group string, priority int64, content string) (*queue.Message, error)
	Dequeue(QueueName string, ack bool) (*queue.Message, error)
	Ack(QueueName string, id uint64) error
	GetByID(id uint64) (*queue.Message, error)
	UpdatePriority(queueName string, id uint64, priority int64) error
}

type Proxy struct {
	// contains filtered or unexported fields
}

type Service struct {
	// contains filtered or unexported fields
}

type UpdatePriorityInput struct {
	QueueName string `path:"queue_name" maxLength:"1024" example:"user_indexing_queue" doc:"Name of the queue"`
	ID        uint64 `path:"id" example:"123" doc:"ID of the message"`
	Body      UpdatePriorityInputBody
}

type UpdatePriorityInputBody struct {
	Priority int64 `json:"priority" minimum:"0" example:"60" doc:"Priority of the message"`
}

type UpdatePriorityOutput struct {
	Status int
	Body   UpdatePriorityOutputBody
}

type UpdatePriorityOutputBody struct {
	Status   string `json:"status" example:"ENQUEUED" doc:"Status of the enqueue operation"`
	ID       uint64 `json:"id" doc:"ID of the message"`
	Priority int64  `json:"priority" minimum:"0" example:"60" doc:"Priority of the message"`
}