Versions in this module Expand all Collapse all v1 v1.0.1 Jan 15, 2025 v1.0.0 Jan 2, 2025 Changes in this version + type DoWorkerActionFunc func(di *dig.Container, op *JobParam) error + func (f DoWorkerActionFunc) YieldWorkerFunc(di *dig.Container, op *JobParam) IWorker + type IWorker interface + Actions func() []string + Debug func() + Interval func() time.Duration + Name func() string + Op func() *JobParam + Params func() map[string]string + Run func(int64) + Start func() + Stop func() + type IWorkerMonitor interface + SetMonitor func(chan metrics.IndicData) + type JobParam struct + Action string + ExtendParams configstc.CommonExtendParams + Interval time.Duration + OpId string + Statistical bool + func (op *JobParam) ExtendParamByBool(k string, def ...bool) bool + func (op *JobParam) ExtendParamByFloat(k string, def ...float64) float64 + func (op *JobParam) ExtendParamByInt(k string, def ...int) int + func (op *JobParam) ExtendParamValue(k string, def ...string) string + type YieldWorkerFunc func(di *dig.Container, op *JobParam) IWorker
Go to main page