Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

repository

package

Go to main page

Versions in this module

v1

v1.2.0

Jan 25, 2026

Changes in this version

+ type AttemptMismatchError struct

+ ActualAttempt string

+ ExpectedAttempt string

+ MessageID string

+ QueueName string

+ func (e *AttemptMismatchError) Error() string

+ type BackendStorage interface

+ AcknowledgeMessage func(ctx context.Context, queueName string, messageId string, attemptId string) error

+ ClaimMessage func(ctx context.Context, queueName string, workerId string, attemptId string) (*messagepb.Message, error)

+ Close func() error

+ CreateQueue func(ctx context.Context, queue *queuepb.Queue) error

+ CreateSchedule func(ctx context.Context, schedule *schedulepb.Schedule) error

+ DeleteDLQMessage func(ctx context.Context, queueName string, messageId string) error

+ DeleteQueue func(ctx context.Context, name string) error

+ DeleteSchedule func(ctx context.Context, scheduleId string) error

+ EnqueueMessage func(ctx context.Context, queueName string, message *messagepb.Message) error

+ ExtendMessageLease func(ctx context.Context, queueName string, messageId string, attemptId string, ...) error

+ GetDLQMessages func(ctx context.Context, queueName string, limit int32) ([]*messagepb.Message, error)

+ GetQueue func(ctx context.Context, name string) (*queuepb.Queue, error)

+ GetQueueMetadata func(ctx context.Context, name string) (*queuepb.QueueMetadata, error)

+ GetSchedule func(ctx context.Context, scheduleId string) (*schedulepb.Schedule, error)

+ GetScheduleHistory func(ctx context.Context, scheduleId string, limit int64) (*schedulepb.ScheduleHistory, error)

+ HeartbeatMessage func(ctx context.Context, queueName string, messageId string, attemptId string) error

+ ListQueues func(ctx context.Context) ([]*queuepb.Queue, error)

+ ListSchedules func(ctx context.Context, queueName string) ([]*schedulepb.Schedule, error)

+ NackMessage func(ctx context.Context, queueName string, messageId string, attemptId string) error

+ PauseSchedule func(ctx context.Context, scheduleId string) error

+ PeekMessages func(ctx context.Context, queueName string, limit int32) ([]*messagepb.Message, error)

+ PurgeDLQ func(ctx context.Context, queueName string) (int64, error)

+ RecordScheduleExecution func(ctx context.Context, scheduleId string, messageId string, executionTime int64) error

+ ResumeSchedule func(ctx context.Context, scheduleId string) error

+ RetryDLQMessage func(ctx context.Context, queueName string, messageId string) error

+ type BackendType string

+ const BackendPostgres

+ const BackendSQLite

+ type InvalidStateTransitionError struct

+ CurrentState string

+ Entity string

+ ID string

+ TargetState string

+ func (e *InvalidStateTransitionError) Error() string

+ type MessageNotFoundError struct

+ MessageID string

+ QueueName string

+ func (e *MessageNotFoundError) Error() string

+ type QueueNotFoundError struct

+ QueueName string

+ func (e *QueueNotFoundError) Error() string

+ type ScheduleNotFoundError struct

+ QueueName string

+ ScheduleID string

+ func (e *ScheduleNotFoundError) Error() string

type Storage

+ func NewPostgresStorage(ctx context.Context, config *postgres.Config) (Storage, error)

+ func NewSQLiteStorage(ctx context.Context, config *sqlite.Config) (Storage, error)

v1.1.1

Dec 7, 2025

v1.1.0

Nov 16, 2025

v1.0.0

Nov 13, 2025

Changes in this version

+ const CANCELED

+ const COMPLETED

+ const DefaultLeaseRenewal

+ const DefaultThresholdPercentage

+ const ERRORED

+ const INVISIBLE

+ const MaxPriority

+ const MinPriority

+ const PENDING

+ const RUNNING

+ const UNDEFINED

+ type ChronoHandlerFunc func(ctx context.Context, req interface{}) (interface{}, error)

+ func ErrorHandler(defaultResp interface{}, msg string) ChronoHandlerFunc

+ type DLQStats struct

+ CreatedAt int64

+ MessageCount int64

+ Name string

+ UpdatedAt int64

+ type KeyChecker struct

+ func NewKeyChecker(rdb *redis.Client, batchSize int) *KeyChecker

+ func (c *KeyChecker) Add(key string)

+ func (c *KeyChecker) Start(ctx context.Context)

+ func (c *KeyChecker) Stop() int

+ type ReclaimService struct

+ func NewReclaimService(storage *storage, interval time.Duration) *ReclaimService

+ func (r *ReclaimService) Start(ctx context.Context)

+ func (r *ReclaimService) Stop()

+ type Scheduler struct

+ func NewScheduler(storage *storage, interval time.Duration) *Scheduler

+ func (s *Scheduler) Start(ctx context.Context)

+ func (s *Scheduler) Stop()

+ type Storage interface

+ AcknowledgeMessage func(ctx context.Context, request *queueservice_pb.AcknowledgeMessageRequest) (*queueservice_pb.AcknowledgeMessageResponse, error)

+ CreateQueue func(ctx context.Context, request *queueservice_pb.CreateQueueRequest) (*queueservice_pb.CreateQueueResponse, error)

+ CreateQueueMessage func(ctx context.Context, request *queueservice_pb.PostMessageRequest, ...) (*queueservice_pb.PostMessageResponse, error)

+ CreateSchedule func(ctx context.Context, request *queueservice_pb.CreateScheduleRequest) (*queueservice_pb.CreateScheduleResponse, error)

+ DeleteFromDLQ func(ctx context.Context, dlqName string, messageID string) error

+ DeleteQueue func(ctx context.Context, request *queueservice_pb.DeleteQueueRequest) (*queueservice_pb.DeleteQueueResponse, error)

+ DeleteQueueMessage func(ctx context.Context, queueName string, messageID string) error

+ DeleteSchedule func(ctx context.Context, request *queueservice_pb.DeleteScheduleRequest) (*queueservice_pb.DeleteScheduleResponse, error)

+ GetCalendarSchedulePreview func(ctx context.Context, calendarSchedule *schedule_pb.CalendarSchedule, count int) (*queueservice_pb.PreviewCalendarScheduleResponse, error)

+ GetDLQMessages func(ctx context.Context, dlqName string, limit int32) ([]*message_pb.Message, error)

+ GetDLQStats func(ctx context.Context, dlqName string) (*DLQStats, error)

+ GetQueueMessage func(ctx context.Context, request *queueservice_pb.GetNextMessageRequest) (*queueservice_pb.GetNextMessageResponse, error)

+ GetQueueMetadata func(ctx context.Context, queueName string) (*queue_pb.QueueMetadata, error)

+ GetQueueState func(ctx context.Context, request *queueservice_pb.GetQueueStateRequest) (*queueservice_pb.GetQueueStateResponse, error)

+ GetSchedule func(ctx context.Context, request *queueservice_pb.GetScheduleRequest) (*queueservice_pb.GetScheduleResponse, error)

+ GetScheduleHistory func(ctx context.Context, request *queueservice_pb.GetScheduleHistoryRequest) (*queueservice_pb.GetScheduleHistoryResponse, error)

+ ListQueues func(ctx context.Context, request *queueservice_pb.ListQueuesRequest) (*queueservice_pb.ListQueuesResponse, error)

+ ListSchedules func(ctx context.Context, request *queueservice_pb.ListSchedulesRequest) (*queueservice_pb.ListSchedulesResponse, error)

+ PauseSchedule func(ctx context.Context, request *queueservice_pb.PauseScheduleRequest) (*queueservice_pb.PauseScheduleResponse, error)

+ PeekQueueMessages func(ctx context.Context, request *queueservice_pb.PeekQueueMessagesRequest) (*queueservice_pb.PeekQueueMessagesResponse, error)

+ PurgeDLQ func(ctx context.Context, dlqName string) error

+ RenewMessageLease func(ctx context.Context, request *queueservice_pb.RenewMessageLeaseRequest) (*queueservice_pb.RenewMessageLeaseResponse, error)

+ RequeueFromDLQ func(ctx context.Context, dlqName string, messageID string, targetQueueName string, ...) error

+ ResumeSchedule func(ctx context.Context, request *queueservice_pb.ResumeScheduleRequest) (*queueservice_pb.ResumeScheduleResponse, error)

+ SendMessageHeartBeat func(ctx context.Context, request *queueservice_pb.SendMessageHeartBeatRequest) (*queueservice_pb.SendMessageHeartBeatResponse, error)

+ ValidateCalendarSchedule func(ctx context.Context, calendarSchedule *schedule_pb.CalendarSchedule) error

+ func NewQueueStorage(ctx context.Context, redisClient *redis.Client, ...) Storage

+ func NewQueueStorageForTesting(redisClient *redis.Client, ...) Storage

+ func NewQueueStorageWithIntervals(ctx context.Context, redisClient *redis.Client, ...) Storage