Versions in this module Expand all Collapse all v1 v1.0.1 Nov 17, 2022 Changes in this version + type Dcron struct + ServerName string + func NewDcron(serverName string, driver driver.Driver, cronOpts ...cron.Option) *Dcron + func NewDcronWithOption(serverName string, driver driver.Driver, dcronOpts ...Option) *Dcron + func (d *Dcron) AddFunc(jobName, cronStr string, cmd func()) (err error) + func (d *Dcron) AddJob(jobName, cronStr string, job Job) (err error) + func (d *Dcron) GetLogger() interface{ ... } + func (d *Dcron) Remove(jobName string) + func (d *Dcron) Run() + func (d *Dcron) SetLogger(logger *log.Logger) + func (d *Dcron) Start() + func (d *Dcron) Stop() + type Job interface + Run func() + type JobWarpper struct + CronStr string + Dcron *Dcron + Func func() + ID cron.EntryID + Job Job + Name string + func (job JobWarpper) Run() + type NodePool struct + Driver driver.Driver + NodeID string + func (np *NodePool) PickNodeByJobName(jobName string) string + func (np *NodePool) StartPool() error + type Option func(*Dcron) + func CronOptionChain(wrappers ...cron.JobWrapper) Option + func CronOptionLocation(loc *time.Location) Option + func CronOptionParser(p cron.ScheduleParser) Option + func CronOptionSeconds() Option + func WithHashReplicas(d int) Option + func WithLogger(logger interface{ ... }) Option + func WithNodeUpdateDuration(d time.Duration) Option
Go to main page