Documentation
¶
Index ¶
Constants ¶
View Source
const DXTaskDefaultAfterDelaySec = 1
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type DXTask ¶
type DXTask struct {
NameId string
StartAt string
AfterDelaySec int64
OnExecute DXTaskOnExecute
Log log.DXLog
RuntimeIsActive bool
Context context.Context
Cancel context.CancelFunc
}
func (*DXTask) ApplyConfigurations ¶
func (*DXTask) StartShutdown ¶
type DXTaskManager ¶
type DXTaskManager struct {
Context context.Context
Cancel context.CancelFunc
Tasks map[string]*DXTask
ErrorGroup *errgroup.Group
ErrorGroupContext context.Context
}
var Manager DXTaskManager
func (*DXTaskManager) NewTask ¶
func (am *DXTaskManager) NewTask(nameId string, startAt string, afterDelaySec int64, onExecute DXTaskOnExecute) (*DXTask, error)
func (*DXTaskManager) StopAll ¶
func (am *DXTaskManager) StopAll() (err error)
type DXTaskOnExecute ¶
Click to show internal directories.
Click to hide internal directories.