task

package
v1.127.1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Oct 9, 2026 License: MIT Imports: 9 Imported by: 0

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 (a *DXTask) ApplyConfigurations() (err error)

func (*DXTask) StartAndWait

func (a *DXTask) StartAndWait(errorGroup *errgroup.Group) error

func (*DXTask) StartShutdown

func (a *DXTask) StartShutdown() (err error)

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) StartAll

func (am *DXTaskManager) StartAll(errorGroup *errgroup.Group, errorGroupContext context.Context) error

func (*DXTaskManager) StopAll

func (am *DXTaskManager) StopAll() (err error)

type DXTaskOnExecute

type DXTaskOnExecute func(task *DXTask) error

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL