crontab

package

v0.0.0-...-9c17c29 Latest Latest Go to latest Published: Jan 14, 2026 License: Apache-2.0 Imports: 7 Imported by: 0

Details

This section is empty.

View Source

var DefaultCronManger = NewCronTabManger("DefaultCronManger")

View Source

var DefaultInterval = time.Second * 5

func AddCronJob(spec string, job cron.Job) (cron.EntryID, error)

func Close()

func GetCron() *cron.Cron

func RemoveCronJob(id cron.EntryID)

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

func NewCronTabManger(name string) *CronManger

func (c *CronManger) AddCronJob(spec string, job cron.Job) (cron.EntryID, error)

func (c *CronManger) Close()

func (c *CronManger) GetCron() *cron.Cron

func (c *CronManger) RemoveCronJob(id cron.EntryID)

func (c *CronManger) Start() error

type Opt func(job *regularJob)

func WithIgnorePanic() Opt

WithIgnorePanic run again when panic

func WithImmediately() Opt

func WithInterval(interval time.Duration) Opt

WithInterval the execution interval time of job

type RegularJob interface {
	Run()
	Stop()
}

func NewRegularJob(name string, fn func(), opts ...Opt) RegularJob