cronworker

Dec 15, 2021

Changes in this version

+ func CreateCronJobKey(jobName, args, interval string) string

+ func ParseCronJobKey(str string) (jobName, args, interval string)

+ type CronJobKey struct

+ Args string

+ Interval string

+ JobName string

+ func (c CronJobKey) String() string

Nov 12, 2021

Changes in this version

type OptionFunc

+ func SetLocker(locker candiutils.Locker) OptionFunc

Aug 22, 2021

Changes in this version

+ type OptionFunc func(*option)

+ func SetConsul(consul *candiutils.Consul) OptionFunc

+ func SetDebugMode(debugMode bool) OptionFunc

+ func SetMaxGoroutines(maxGoroutines int) OptionFunc

Jul 29, 2021

Changes in this version

type Job

+ Handler types.WorkerHandler

May 4, 2021

Changes in this version

+ func AddJob(job Job) error

+ func NewWorker(service factory.ServiceFactory) factory.AppServerFactory

+ func UpdateIntervalActiveJob(jobNumber int, newInterval string) (err error)

+ type Job struct

+ HandlerFunc types.WorkerHandlerFunc

+ HandlerName string

+ Interval string

+ Params string

+ WorkerIndex int

+ func GetActiveJobs() []*Job