schedule

Documentation

Index

• type ArgOption
  • func OnOneServer(rdb *redis.Client, key string, ttl time.Duration) ArgOption
• type AutoLock
  • 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 NewSchedule(logger log.Logger) *Schedule
  • func (s Schedule) Add(name string, spec string, job func() error, opts ...ArgOption) (cron.EntryID, error)
  • func (s Schedule) AddCtx(ctx context.Context, name string, spec string, ...) (cron.EntryID, error)
  • func (s Schedule) Start() error
  • func (s Schedule) Stop() error

Types

type ArgOption

type ArgOption func(*scheduleArgs)

func OnOneServer

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

type AutoLock

type AutoLock struct {
	// contains filtered or unexported fields
}

func TryLock

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

TryLock attempts to acquire a distributed lock and starts automatic renewal.

func (*AutoLock) Release

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

Release stops the auto-renewal process and releases the lock.

type Schedule

type Schedule struct {
	// contains filtered or unexported fields
}

func NewSchedule

func NewSchedule(logger log.Logger) *Schedule

func (Schedule) Add

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

func (Schedule) AddCtx

func (s Schedule) AddCtx(ctx context.Context, name string, spec string, job func(ctx2 context.Context) error, opts ...ArgOption) (cron.EntryID, error)

func (Schedule) Start

func (s Schedule) Start() error

func (Schedule) Stop

func (s Schedule) Stop() error