scheduler

Documentation

Index

• type Job
• type RepeatPolicy
• type Scheduler
  • func New() *Scheduler
  • func (scheduler *Scheduler) AddAfter(duration time.Duration, fn func()) string
  • func (scheduler *Scheduler) AddAt(tm time.Time, fn func()) string
  • func (scheduler *Scheduler) Cancel(id string) bool
  • func (scheduler *Scheduler) Latest() (string, time.Time, bool)
  • func (scheduler *Scheduler) Len() int
  • func (scheduler *Scheduler) Peek() (string, time.Time, bool)
  • func (scheduler *Scheduler) Pop() bool
  • func (scheduler *Scheduler) Run(ctx context.Context)

Types

type Job

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

type RepeatPolicy

type RepeatPolicy interface {
	Next(after time.Time) time.Time
}

type Scheduler

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

func New

func New() *Scheduler

func (*Scheduler) AddAfter

func (scheduler *Scheduler) AddAfter(duration time.Duration, fn func()) string

func (*Scheduler) AddAt

func (scheduler *Scheduler) AddAt(tm time.Time, fn func()) string

func (*Scheduler) Cancel

func (scheduler *Scheduler) Cancel(id string) bool

func (*Scheduler) Latest

func (scheduler *Scheduler) Latest() (string, time.Time, bool)

func (*Scheduler) Len

func (scheduler *Scheduler) Len() int

func (*Scheduler) Peek

func (scheduler *Scheduler) Peek() (string, time.Time, bool)

func (*Scheduler) Pop

func (scheduler *Scheduler) Pop() bool

func (*Scheduler) Run

func (scheduler *Scheduler) Run(ctx context.Context)