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     string `json:"id" doc:"ID of the message"`
}

type BackupInput struct {
	Body struct {
		Since uint64 `json:"since" example:"0" doc:"Minimum version of the log to include in the backup"`
	}
}

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"`
	Settings QueueSettings `json:"settings" doc:"Configuration 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"`
	Settings QueueSettings `json:"settings" doc:"Configuration of the queue"`
}

type DeleteInput 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 DeleteOutput struct {
	Status int
}

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       string            `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"`
	Metadata map[string]string `json:"metadata,omitempty" example:"{\"retry\": \"0\"}" doc:"Metadata 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 {
	ID       string            `json:"id,omitempty" 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"`
	Metadata map[string]string `json:"metadata,omitempty" example:"{\"retry\": \"0\"}" doc:"Metadata 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       string            `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"`
	Metadata map[string]string `json:"metadata,omitempty" example:"{\"retry\": \"0\"}" doc:"Metadata of the message"`
}

type GenerateIdInput struct {
	Body GenerateIdInputBody
}

type GenerateIdInputBody struct {
	Number int `json:"number" minimum:"1" maximum:"1000" example:"1" doc:"Number of IDs to generate"`
}

type GenerateIdOutput struct {
	Status int
	Body   GenerateIdOutputBody
}

type GenerateIdOutputBody struct {
	IDs []string `json:"ids" doc:"List of generated IDs"`
}

type GetInput 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 GetOutput struct {
	Status int
	Body   GetOutputBody
}

type GetOutputBody struct {
	Status   string            `json:"status" example:"DEQUEUED" doc:"Status of the dequeue operation"`
	ID       string            `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"`
	Metadata map[string]string `json:"metadata,omitempty" example:"{\"retry\": \"0\"}" doc:"Metadata 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 JoinOutputBody
}

type JoinOutputBody 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 NackInput 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      NackInputBody
}

type NackInputBody struct {
	Priority int64             `json:"priority" minimum:"0" example:"60" doc:"Priority of the message"`
	Metadata map[string]string `json:"metadata,omitempty" example:"{\"retry\": \"0\"}" doc:"Metadata of the message"`
}

type NackOutput struct {
	Status int
	Body   NackOutputBody
}

type NackOutputBody struct {
	Status   string            `json:"status" example:"UNACKNOWLEDGED" doc:"Status of the dequeue operation"`
	ID       string            `json:"id" doc:"ID of the message"`
	Priority int64             `json:"priority" minimum:"0" example:"60" doc:"Priority of the message"`
	Metadata map[string]string `json:"metadata,omitempty" example:"{\"retry\": \"0\"}" doc:"Metadata of the message"`
}

type Node interface {
	Join(nodeID string, addr string) error
	PrometheusRegistry() prometheus.Registerer
	IsLeader() bool
	GenerateID() uint64
	CreateQueue(queueType, queueName string, settings entity.QueueSettings) error
	DeleteQueue(queueName string) error
	GetQueues() []*queue.QueueInfo
	GetQueueInfo(queueName string) (*queue.QueueInfo, error)
	Enqueue(
		queueName string,
		id uint64,
		group string,
		priority int64,
		content string,
		metadata map[string]string,
	) (*entity.Message, error)
	Dequeue(QueueName string, ack bool) (*entity.Message, error)
	Get(QueueName string, id uint64) (*entity.Message, error)
	Delete(QueueName string, id uint64) error
	Ack(QueueName string, id uint64) error
	Nack(QueueName string, id uint64, priority int64, metadata map[string]string) error
	UpdatePriority(queueName string, id uint64, priority int64) error
	Backup(w io.Writer, since uint64) (uint64, error)
	Restore(r io.Reader, maxPendingWrites int) error
}

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

type QueueInfoOutput struct {
	Status int
	Body   QueueInfoOutputBody
}

type QueueInfoOutputBody 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"`
	Settings   QueueSettings `json:"settings" doc:"Configuration of the queue"`
	EnqueueRPS float64       `json:"enqueue_rps" doc:"Rate of enqueued messages per second"`
	DequeueRPS float64       `json:"dequeue_rps" doc:"Rate of dequeued messages per second"`
	AckRPS     float64       `json:"ack_rps" doc:"Rate of acknowledged messages per second"`
	NackRPS    float64       `json:"nack_rps" doc:"Rate of unacknowledged messages per second"`
	Ready      int64         `json:"ready" doc:"Number of ready messages"`
	Unacked    int64         `json:"unacked" doc:"Number of unacknowledged messages"`
	Total      int64         `json:"total" doc:"Total number of messages"`
}

type QueueOutput 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"`
	Settings   QueueSettings `json:"settings" doc:"Configuration of the queue"`
	EnqueueRPS float64       `json:"enqueue_rps" doc:"Rate of enqueued messages per second"`
	DequeueRPS float64       `json:"dequeue_rps" doc:"Rate of dequeued messages per second"`
	AckRPS     float64       `json:"ack_rps" doc:"Rate of acknowledged messages per second"`
	NackRPS    float64       `json:"nack_rps" doc:"Rate of unacknowledged messages per second"`
	Ready      int64         `json:"ready" doc:"Number of ready messages"`
	Unacked    int64         `json:"unacked" doc:"Number of unacknowledged messages"`
	Total      int64         `json:"total" doc:"Total number of messages"`
}

type QueueSettings struct {
	Strategy   string `` /* 131-byte string literal not displayed */
	MaxUnacked int    `json:"max_unacked,omitempty" minimum:"1" example:"7" doc:"Maximum expected unacknowledged messages in the queue"`
}

type QueuesInput struct {
}

type QueuesOutput struct {
	Status int
	Body   QueuesOutputBody
}

type QueuesOutputBody struct {
	Queues []QueueOutput `json:"queues"`
}

type RestoreInput struct {
	RawBody huma.MultipartFormFiles[struct {
		File huma.FormFile `form:"file" contentType:"application/octet-stream" required:"true"`
	}]
}

type RestoreOutput struct {
	Status int
	Body   RestoreOutputBody
}

type RestoreOutputBody struct {
	Status string `json:"status" example:"SUCCEDED" doc:"Status of the restore operation"`
}

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       string `json:"id" doc:"ID of the message"`
	Priority int64  `json:"priority" minimum:"0" example:"60" doc:"Priority of the message"`
}