timers

README

定时任务功能包

Documentation

Index

• type RunFunc
• type Timer
  • func NewTimer(ctx context.Context, singletonKey string, store kv.Store) *Timer
  • func (s *Timer) Create(keys []string, cron string, runFunc RunFunc) error
  • func (s *Timer) Delete(key string) error
  • func (s *Timer) IsRunning() bool
  • func (s *Timer) Start(startFunc func(ctx context.Context))
• type TimerControl

Types

type RunFunc

type RunFunc func(ctx context.Context) error

type Timer

type Timer struct {
	logx.Logger
	// contains filtered or unexported fields
}

func NewTimer

func NewTimer(ctx context.Context, singletonKey string, store kv.Store) *Timer

func (*Timer) Create

func (s *Timer) Create(keys []string, cron string, runFunc RunFunc) error

func (*Timer) Delete

func (s *Timer) Delete(key string) error

func (*Timer) IsRunning

func (s *Timer) IsRunning() bool

func (*Timer) Start

func (s *Timer) Start(startFunc func(ctx context.Context))

type TimerControl

type TimerControl interface {
	Create(keys []string, cron string, runFunc RunFunc) error
	IsRunning() bool
	Delete(key string) error
	Start(startFunc func(ctx context.Context))
}