chronos

Jul 14, 2026

Changes in this version

type Group

+ func (g *Group) AddChain(ch *Chain) *Group

Jul 14, 2026

Changes in this version

+ const MaxResultSize

+ var ErrNoResult = errors.New("chronos: no result")

+ var ErrResultTooLarge = errors.New("chronos: result exceeds MaxResultSize")

+ func AddHandlerR[T TaskArgs, R any](mux *Mux, fn func(ctx context.Context, task *Task[T]) (R, error))

+ func GroupResults[R any, T TaskArgs](t *Task[T]) ([]R, error)

+ func PrevResult[R any, T TaskArgs](t *Task[T]) (R, error)

type Chain

+ func (ch *Chain) ThenGroup(g *Group) *Chain

type Task

+ func (t *Task[T]) RawGroupResults() [][]byte

type TaskInfo

+ HasResult bool

+ ResultSize int

Jul 12, 2026

Changes in this version

type Inspector

+ func (i *Inspector) PauseQueue(ctx context.Context, qname string) error

+ func (i *Inspector) PausedQueues(ctx context.Context) ([]string, error)

+ func (i *Inspector) ResumeQueue(ctx context.Context, qname string) error

type QueueInfo

+ Paused bool

type ScheduleInfo

+ Kind string

+ LastSeen time.Time

+ Queue string

+ Spec string

+ Stale bool

Jul 12, 2026

Changes in this version

type Inspector

+ func (i *Inspector) GroupMembers(ctx context.Context, cbQueue, groupID string) ([]string, error)

+ func (i *Inspector) SchedulerStatus(ctx context.Context) (*SchedulerStatus, error)

+ type ScheduleInfo struct

+ ID string

+ LastFired time.Time

+ type SchedulerStatus struct

+ LeaderID string

+ Schedules []ScheduleInfo

type TaskInfo

+ ChainIndex int

+ ChainNext []string

+ GroupQueue string

Jul 12, 2026

Changes in this version

+ type Group struct

+ func NewGroup() *Group

+ func (g *Group) Add(args TaskArgs, opts ...Option) *Group

+ func (g *Group) Enqueue(ctx context.Context, c *Client) (*GroupInfo, error)

+ func (g *Group) OnComplete(args TaskArgs, opts ...Option) *Group

+ type GroupInfo struct

+ CallbackID string

+ GroupID string

+ MemberIDs []string

type TaskInfo

+ GroupID string

+ GroupPending int

Jul 12, 2026

Changes in this version

+ type Chain struct

+ func NewChain() *Chain

+ func (ch *Chain) Enqueue(ctx context.Context, c *Client) (*TaskInfo, error)

+ func (ch *Chain) Then(args TaskArgs, opts ...Option) *Chain

type TaskInfo

+ ChainPending int

Jul 11, 2026

Changes in this version

type Option

+ func WithRetention(d time.Duration) Option

type QueueInfo

+ Completed int64

type ServerConfig

+ MaxCompleted int

type TaskInfo

+ CompletedAt time.Time

Jul 11, 2026

Changes in this version

+ var ErrInvalidState = errors.New("chronos: invalid task state")

+ var ErrTaskNotFound = errors.New("chronos: task not found")

type Inspector

+ func (i *Inspector) GetTask(ctx context.Context, qname, taskID string) (*TaskInfo, error)

type TaskInfo

+ LastErr string

+ MaxRetry int

+ NextProcessAt time.Time

+ Payload []byte

+ Retried int

+ State string

Jul 9, 2026

Changes in this version

type ServerConfig

+ StrictPriority bool

Jul 8, 2026

Changes in this version

+ const DefaultMaxRetry

+ const DefaultQueue

+ var ErrDuplicateTask = rdb.ErrDuplicateTask

+ func AddHandler[T TaskArgs](mux *Mux, fn func(ctx context.Context, task *Task[T]) error)

+ func DefaultRetryDelay(retried int, _ error) time.Duration

+ func RegisterCron[T TaskArgs](s *Scheduler, spec string, args T, opts ...Option) error

+ func RegisterInterval[T TaskArgs](s *Scheduler, interval time.Duration, args T, opts ...Option) error

+ func SkipRetry(err error) error

+ type Client struct

+ func NewClient(r redis.UniversalClient) *Client

+ func (c *Client) Close() error

+ type Inspector struct

+ func NewInspector(r redis.UniversalClient) *Inspector

+ func (i *Inspector) DeleteTask(ctx context.Context, qname, taskID string) error

+ func (i *Inspector) ListTasks(ctx context.Context, qname, state string, limit int) ([]*TaskInfo, error)

+ func (i *Inspector) Queues(ctx context.Context) ([]*QueueInfo, error)

+ func (i *Inspector) RunTask(ctx context.Context, qname, taskID string) error

+ type Metrics interface

+ ObserveTask func(queue, kind string, outcome TaskOutcome, dur time.Duration)

+ type MisfirePolicy int

+ const MisfireFireOnce

+ const MisfireSkip

+ type Mux struct

+ func NewMux() *Mux

+ type Option interface

+ func WithDeadLetterDiscard() Option

+ func WithMaxRetry(n int) Option

+ func WithMisfirePolicy(p MisfirePolicy) Option

+ func WithProcessAt(t time.Time) Option

+ func WithProcessIn(d time.Duration) Option

+ func WithQueue(name string) Option

+ func WithTaskID(id string) Option

+ func WithUnique(ttl time.Duration) Option

+ type QueueInfo struct

+ Active int64

+ Archived int64

+ Pending int64

+ Queue string

+ Retry int64

+ Scheduled int64

+ type RetryDelayFunc func(retried int, err error) time.Duration

+ type Scheduler struct

+ func NewScheduler(r redis.UniversalClient, cfg SchedulerConfig) *Scheduler

+ func (s *Scheduler) Shutdown(ctx context.Context) error

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

+ type SchedulerConfig struct

+ LeaderTTL time.Duration

+ Location *time.Location

+ Logger *slog.Logger

+ type Server struct

+ func NewServer(r redis.UniversalClient, cfg ServerConfig) *Server

+ func (s *Server) Shutdown(ctx context.Context) error

+ func (s *Server) Start(ctx context.Context, mux *Mux) error

+ type ServerConfig struct

+ ArchivedRetention time.Duration

+ Concurrency int

+ ForwardInterval time.Duration

+ HeartbeatInterval time.Duration

+ JanitorInterval time.Duration

+ Logger *slog.Logger

+ MaxArchived int

+ Metrics Metrics

+ OnDeadLetter func(ctx context.Context, info *TaskInfo, err error)

+ Queues map[string]int

+ RecoverInterval time.Duration

+ RecoverMinIdle time.Duration

+ RetryDelayFunc RetryDelayFunc

+ type Task struct

+ Args T

+ func (t *Task[T]) ID() string

+ func (t *Task[T]) Queue() string

+ type TaskArgs interface

+ Kind func() string

+ type TaskInfo struct

+ ID string

+ Kind string

+ Queue string

+ func Enqueue[T TaskArgs](ctx context.Context, c *Client, args T, opts ...Option) (*TaskInfo, error)

+ type TaskOutcome string

+ const OutcomeDeadLetter

+ const OutcomeRetry

+ const OutcomeSuccess