timertask

Nov 12, 2026

Changes in this version

+ const ErrKey

Nov 11, 2026

Changes in this version

+ var ErrBackendAlreadyStarted = errors.New("timertask: backend already started")

+ func NormalizeRetry(task *Task)

+ type RetryHooks struct

+ Interrupted func() bool

+ OnError func(err error)

+ OnInterrupted func()

+ OnRetry func(attempt, maxRetry int)

+ type RetryOutcome int

+ const RetryExhausted

+ const RetryInterrupted

+ const RetrySuccess

+ func RunWithRetry(ctx context.Context, task *Task, handler Handler, retryDelay time.Duration, ...) (RetryOutcome, error)

Nov 10, 2026

Changes in this version

type BackendConfig

+ Clock Clock

Nov 8, 2026

Changes in this version

+ var ErrBackendStopped = errors.New("timertask: backend stopped")

Nov 6, 2026

Changes in this version

+ type Clock interface

+ Now func() time.Time

+ type SystemClock struct

+ func (SystemClock) Now() time.Time

type TimerTaskOption

+ func WithClock(clock Clock) TimerTaskOption

Oct 28, 2026

Changes in this version

+ var ErrEmptyTaskID = errors.New("timertask: task ID must not be empty")

Oct 19, 2026

Changes in this version

+ type BackendConfig struct

+ Buckets int

+ Delivery DeliveryMode

+ OnFailure func(*Task, error)

+ RetryCount int

+ RetryDelay time.Duration

+ VisibilityTimeout time.Duration

+ Workers int

+ func ResolveOptions(opts ...TimerTaskOption) BackendConfig

Oct 17, 2026

Changes in this version

+ type DeliveryMode int

+ const DeliveryAtLeastOnce

+ const DeliveryAtMostOnce

type TimerTaskOption

+ func WithAtLeastOnce(visibilityTimeout time.Duration) TimerTaskOption

+ func WithDeliveryMode(m DeliveryMode) TimerTaskOption

+ func WithVisibilityTimeout(d time.Duration) TimerTaskOption

Oct 15, 2026

Changes in this version

+ type Handler func(ctx context.Context, task *Task) error

+ type LocalBackend struct

+ func NewLocalBackend(handler Handler, opts ...TimerTaskOption) *LocalBackend

+ func (b *LocalBackend) LocalPendingCount() int

+ func (b *LocalBackend) PendingCount(ctx context.Context) (int64, error)

+ func (b *LocalBackend) Send(ctx context.Context, task *Task) error

+ func (b *LocalBackend) Start(ctx context.Context) error

+ type RedisBackend struct

+ func NewRedisBackend(buzType string, client redis.UniversalClient, handler Handler, ...) *RedisBackend

+ func (b *RedisBackend) LocalPendingCount() int

+ func (b *RedisBackend) PendingCount(ctx context.Context) (int64, error)

+ func (b *RedisBackend) Send(ctx context.Context, task *Task) error

+ func (b *RedisBackend) Start(ctx context.Context) error

+ type ShardManager struct

+ func NewShardManager(buzType string, client redis.UniversalClient, totalShards int) *ShardManager

+ func (s *ShardManager) GetClientID() string

+ func (s *ShardManager) GetMyShards() []int

+ func (s *ShardManager) StartAssign(ctx context.Context)

+ func (s *ShardManager) StartHeartbeat(ctx context.Context)

+ type Task struct

+ Action string

+ CreateTime int64

+ EndTime int64

+ Extra string

+ ID string

+ MaxRetry int

+ Param string

+ RetryCount int

+ type TimerTask interface

+ LocalPendingCount func() int

+ PendingCount func(ctx context.Context) (int64, error)

+ Send func(ctx context.Context, task *Task) error

+ Start func(ctx context.Context) error

+ type TimerTaskOption func(*config)

+ func WithBuckets(n int) TimerTaskOption

+ func WithOnFailure(fn func(task *Task, err error)) TimerTaskOption

+ func WithRetry(count int, delay time.Duration) TimerTaskOption

+ func WithWorkers(n int) TimerTaskOption