cron

Documentation

Index

• type ConsumeHandle
• type Cron
  • func New(options ...Option) (d *Cron)
  • func New1(options ...Option) (d *Cron, cf func())
  • func (c *Cron) AddFunc(spec string, cmd func()) (EntryID, error)
  • func (c *Cron) AddJob(spec string, cmd Job) (EntryID, error)
  • func (c *Cron) Remove(id EntryID)
  • func (c *Cron) Start() error
  • func (c *Cron) Stop() error
• type EntryID
• type Job
• type Logger
  • func NewLogger(core zapcore.Core, lvl zapcore.Level) *Logger
  • func (l Logger) Enabled(lvl zapcore.Level) bool
  • func (s *Logger) Error(err error, msg string, keysAndValues ...interface{})
  • func (s *Logger) Info(msg string, keysAndValues ...interface{})
• type Option
  • func WithLogLevel(lvl zapcore.Level) Option
  • func WithSpec(spec string, handler ConsumeHandle) Option
• type Pair

Types

type ConsumeHandle

type ConsumeHandle func(ctx context.Context) error

type Cron

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

func New

func New(options ...Option) (d *Cron)

New 新cron

func New1

func New1(options ...Option) (d *Cron, cf func())

func (*Cron) AddFunc

func (c *Cron) AddFunc(spec string, cmd func()) (EntryID, error)

func (*Cron) AddJob

func (c *Cron) AddJob(spec string, cmd Job) (EntryID, error)

func (*Cron) Remove

func (c *Cron) Remove(id EntryID)

func (*Cron) Start

func (c *Cron) Start() error

func (*Cron) Stop

func (c *Cron) Stop() error

type EntryID

type EntryID = cron.EntryID

type Job

type Job = cron.Job

type Logger

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

func NewLogger

func NewLogger(core zapcore.Core, lvl zapcore.Level) *Logger

func (Logger) Enabled

func (l Logger) Enabled(lvl zapcore.Level) bool

func (*Logger) Error

func (s *Logger) Error(err error, msg string, keysAndValues ...interface{})

Error logs an error condition.

func (*Logger) Info

func (s *Logger) Info(msg string, keysAndValues ...interface{})

type Option

type Option func(alc *Cron)

func WithLogLevel

func WithLogLevel(lvl zapcore.Level) Option

func WithSpec

func WithSpec(spec string, handler ConsumeHandle) Option

type Pair

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