schedule

Jul 15, 2025

Changes in this version

+ type ArgOption func(*scheduleArgs)

+ func OnOneServer(rdb *redis.Client, key string, ttl time.Duration) ArgOption

+ type AutoLock struct

+ func TryLock(ctx context.Context, rdb *redis.Client, key string, ttl time.Duration) (*AutoLock, error)

+ func (al *AutoLock) Release(ctx context.Context) error

type Schedule

+ func (s Schedule) AddCtx(ctx context.Context, name string, spec string, ...) (cron.EntryID, error)

Oct 8, 2024

Changes in this version

+ type Schedule struct

+ func NewSchedule(logger log.Logger) *Schedule

+ func (s Schedule) Add(name string, spec string, job func() error) (cron.EntryID, error)

+ func (s Schedule) Start() error

+ func (s Schedule) Stop() error