http

Nov 25, 2025

Changes in this version

type Server

+ LeaderAddr string

Nov 6, 2025

Changes in this version

type Handler

+ func (h *Handler) Touch(ctx context.Context, input *TouchInput) (*TouchOutput, error)

type Node

+ Touch func(QueueName string, id uint64) error

+ type TouchInput struct

+ ID uint64

+ QueueName string

+ type TouchOutput struct

+ Body TouchOutputBody

+ Status int

+ type TouchOutputBody struct

+ ID string

+ Status string

Oct 19, 2025

Changes in this version

type Handler

+ func (h *Handler) UpdateQueue(ctx context.Context, input *UpdateQueueInput) (*UpdateQueueOutput, error)

type Node

+ UpdateQueue func(queueName string, settings entity.QueueSettings) error

+ type UpdateQueueInput struct

+ Body UpdateQueueInputBody

+ QueueName string

+ type UpdateQueueInputBody struct

+ Settings QueueSettings

+ type UpdateQueueOutput struct

+ Body UpdateQueueOutputBody

+ Status int

+ type UpdateQueueOutputBody struct

+ Name string

+ Settings QueueSettings

+ Status string

Oct 10, 2025

Changes in this version

type Handler

+ func (h *Handler) Servers(ctx context.Context, input *ServersInput) (*ServersOutput, error)

type Node

+ GetServers func() ([]*entity.Server, error)

+ type Server struct

+ Addr string

+ Id string

+ IsLeader bool

+ Suffrage string

+ type ServersInput struct

+ type ServersOutput struct

+ Body ServersOutputBody

+ type ServersOutputBody struct

+ Servers []Server

Oct 9, 2025

Changes in this version

type Handler

+ func (h *Handler) Leave(ctx context.Context, input *LeaveInput) (*LeaveOutput, error)

+ type LeaveInput struct

+ Body struct{ ... }

+ type LeaveOutput struct

+ Body LeaveOutputBody

+ type LeaveOutputBody struct

+ ID string

type Node

+ Leave func(nodeID string) error

Sep 29, 2025

Changes in this version

type QueueSettings

+ AckTimeout uint32

Sep 4, 2025

Changes in this version

+ type GenerateIdInput struct

+ Body GenerateIdInputBody

+ type GenerateIdInputBody struct

+ Number int

+ type GenerateIdOutput struct

+ Body GenerateIdOutputBody

+ Status int

+ type GenerateIdOutputBody struct

+ IDs []string

type Handler

+ func (h *Handler) GenerateID(ctx context.Context, input *GenerateIdInput) (*GenerateIdOutput, error)

Jun 16, 2025

Changes in this version

type EnqueueInputBody

+ ID string

Jun 13, 2025

Changes in this version

type CreateQueueInputBody

+ Settings QueueSettings

type CreateQueueOutputBody

+ Settings QueueSettings

type QueueInfoOutputBody

+ Settings QueueSettings

type QueueOutput

+ Settings QueueSettings

+ type QueueSettings struct

+ MaxUnacked int

+ Strategy string

Mar 16, 2025

Changes in this version

+ type JoinOutputBody struct

+ Addr string

+ ID string

+ type RestoreOutputBody struct

+ Status string

Feb 20, 2025

Changes in this version

+ type BackupInput struct

+ Body struct{ ... }

type Handler

+ func (h *Handler) Backup(ctx context.Context, input *BackupInput) (*huma.StreamResponse, error)

+ func (h *Handler) Restore(ctx context.Context, input *RestoreInput) (*RestoreOutput, error)

type Node

+ Backup func(w io.Writer, since uint64) (uint64, error)

+ Restore func(r io.Reader, maxPendingWrites int) error

+ type RestoreInput struct

+ RawBody ...

+ type RestoreOutput struct

+ Body struct{ ... }

+ Status int

Feb 10, 2025

Changes in this version

type NackInputBody

+ Priority int64

type NackOutputBody

+ Priority int64

Jan 8, 2025

Changes in this version

+ type DeleteInput struct

+ ID uint64

+ QueueName string

+ type DeleteOutput struct

+ Status int

type DequeueOutputBody

+ Metadata map[string]string

type EnqueueInputBody

+ Metadata map[string]string

type EnqueueOutputBody

+ Metadata map[string]string

+ type GetInput struct

+ ID uint64

+ QueueName string

+ type GetOutput struct

+ Body GetOutputBody

+ Status int

+ type GetOutputBody struct

+ Content string

+ Group string

+ ID string

+ Metadata map[string]string

+ Priority int64

+ Status string

type Handler

+ func (h *Handler) Delete(ctx context.Context, input *DeleteInput) (*DeleteOutput, error)

+ func (h *Handler) Get(ctx context.Context, input *GetInput) (*GetOutput, error)

type NackInput

+ Body NackInputBody

+ type NackInputBody struct

+ Metadata map[string]string

type NackOutputBody

+ Metadata map[string]string

type Node

+ Delete func(QueueName string, id uint64) error

+ Get func(QueueName string, id uint64) (*queue.Message, error)

type Proxy

+ func (p *Proxy) Delete(ctx context.Context, host string, queueName string, id uint64) huma.StatusError

+ func (p *Proxy) Get(ctx context.Context, host string, queueName string, id uint64) (*GetOutputBody, huma.StatusError)

Oct 9, 2024

Changes in this version

type Handler

+ func (h *Handler) Nack(ctx context.Context, input *NackInput) (*NackOutput, error)

+ type NackInput struct

+ ID uint64

+ QueueName string

+ type NackOutput struct

+ Body NackOutputBody

+ Status int

+ type NackOutputBody struct

+ ID uint64

+ Status string

type Node

+ Nack func(QueueName string, id uint64) error

type Proxy

+ func (p *Proxy) Nack(ctx context.Context, host string, queueName string, id uint64) (*NackOutputBody, huma.StatusError)

type QueueInfoOutputBody

+ NackRPS float64

type QueueOutput

+ NackRPS float64

Oct 2, 2024

Changes in this version

type Handler

+ func (h *Handler) QueueInfo(ctx context.Context, input *QueueInfoInput) (*QueueInfoOutput, error)

+ func (h *Handler) Queues(ctx context.Context, input *QueuesInput) (*QueuesOutput, error)

type Node

+ GetQueueInfo func(queueName string) (*queue.QueueInfo, error)

+ GetQueues func() []*queue.QueueInfo

+ PrometheusRegistry func() prometheus.Registerer

+ type QueueInfoInput struct

+ QueueName string

+ type QueueInfoOutput struct

+ Body QueueInfoOutputBody

+ Status int

+ type QueueInfoOutputBody struct

+ AckRPS float64

+ DequeueRPS float64

+ EnqueueRPS float64

+ Name string

+ Ready int64

+ Total int64

+ Type string

+ Unacked int64

+ type QueueOutput struct

+ AckRPS float64

+ DequeueRPS float64

+ EnqueueRPS float64

+ Name string

+ Ready int64

+ Total int64

+ Type string

+ Unacked int64

+ type QueuesInput struct

+ type QueuesOutput struct

+ Body QueuesOutputBody

+ Status int

+ type QueuesOutputBody struct

+ Queues []QueueOutput

Sep 29, 2024

Changes in this version

type Node

+ GenerateID func() uint64

Sep 7, 2024

Changes in this version

type Handler

+ func (h *Handler) Join(ctx context.Context, input *JoinInput) (*JoinOutput, error)

+ type JoinInput struct

+ Body struct{ ... }

+ type JoinOutput struct

+ Body struct{ ... }

type Node

+ Join func(nodeID string, addr string) error

Sep 5, 2024

Changes in this version

+ type AckInput struct

+ ID uint64

+ QueueName string

+ type AckOutput struct

+ Body AckOutputBody

+ Status int

+ type AckOutputBody struct

+ ID uint64

+ Status string

+ type CreateQueueInput struct

+ Body CreateQueueInputBody

+ type CreateQueueInputBody struct

+ Name string

+ Type string

+ type CreateQueueOutput struct

+ Body CreateQueueOutputBody

+ Status int

+ type CreateQueueOutputBody struct

+ Name string

+ Status string

+ Type string

+ type DeleteQueueInput struct

+ QueueName string

+ type DeleteQueueOutput struct

+ Body DeleteQueueOutputBody

+ Status int

+ type DeleteQueueOutputBody struct

+ Status string

+ type DequeueInput struct

+ Ack bool

+ QueueName string

+ type DequeueOutput struct

+ Body DequeueOutputBody

+ Status int

+ type DequeueOutputBody struct

+ Content string

+ Group string

+ ID uint64

+ Priority int64

+ Status string

+ type EnqueueInput struct

+ Body EnqueueInputBody

+ QueueName string

+ type EnqueueInputBody struct

+ Content string

+ Group string

+ Priority int64

+ type EnqueueOutput struct

+ Body EnqueueOutputBody

+ Status int

+ type EnqueueOutputBody struct

+ Content string

+ Group string

+ ID uint64

+ Priority int64

+ Status string

+ type Handler struct

+ func (h *Handler) Ack(ctx context.Context, input *AckInput) (*AckOutput, error)

+ func (h *Handler) ConfigureMiddleware(router *fiber.App)

+ func (h *Handler) CreateQueue(ctx context.Context, input *CreateQueueInput) (*CreateQueueOutput, error)

+ func (h *Handler) DeleteQueue(ctx context.Context, input *DeleteQueueInput) (*DeleteQueueOutput, error)

+ func (h *Handler) Dequeue(ctx context.Context, input *DequeueInput) (*DequeueOutput, error)

+ func (h *Handler) Enqueue(ctx context.Context, input *EnqueueInput) (*EnqueueOutput, error)

+ func (h *Handler) RegisterRoutes(api huma.API)

+ func (h *Handler) UpdatePriority(ctx context.Context, input *UpdatePriorityInput) (*UpdatePriorityOutput, error)

+ type Node interface

+ Ack func(QueueName string, id uint64) error

+ CreateQueue func(queueType, queueName string) error

+ DeleteQueue func(queueName string) error

+ Dequeue func(QueueName string, ack bool) (*queue.Message, error)

+ Enqueue func(queueName string, group string, priority int64, content string) (*queue.Message, error)

+ GetByID func(id uint64) (*queue.Message, error)

+ IsLeader func() bool

+ Leader func() string

+ UpdatePriority func(queueName string, id uint64, priority int64) error

+ type Proxy struct

+ func NewProxy(client *http.Client) *Proxy

+ func (p *Proxy) Ack(ctx context.Context, host string, queueName string, id uint64) (*AckOutputBody, huma.StatusError)

+ func (p *Proxy) CreateQueue(ctx context.Context, host string, body *CreateQueueInputBody) (*CreateQueueOutputBody, huma.StatusError)

+ func (p *Proxy) DeleteQueue(ctx context.Context, host string, queueName string) (*DeleteQueueOutputBody, huma.StatusError)

+ func (p *Proxy) Dequeue(ctx context.Context, host string, queueName string, ack bool) (*DequeueOutputBody, huma.StatusError)

+ func (p *Proxy) Enqueue(ctx context.Context, host string, queueName string, body *EnqueueInputBody) (*EnqueueOutputBody, huma.StatusError)

+ func (p *Proxy) UpdatePriority(ctx context.Context, host string, queueName string, id uint64, ...) (*UpdatePriorityOutputBody, huma.StatusError)

+ type Service struct

+ func NewHttpService(addr string, node Node) *Service

+ func (s *Service) Start() error

+ type UpdatePriorityInput struct

+ Body UpdatePriorityInputBody

+ ID uint64

+ QueueName string

+ type UpdatePriorityInputBody struct

+ Priority int64

+ type UpdatePriorityOutput struct

+ Body UpdatePriorityOutputBody

+ Status int

+ type UpdatePriorityOutputBody struct

+ ID uint64

+ Priority int64

+ Status string