tasks

package

v0.0.6 Latest Latest Go to latest Published: May 7, 2023 License: MIT Imports: 8 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

This section is empty.

View Source

var ErrTaskNotFound = errors.New("task not found")

func Run(ctx context.Context, task Task) (err error)

func RunWorker(ctx context.Context, fn func(ctx context.Context) error, workerNum int) error

type Mapper struct {
	// contains filtered or unexported fields
}

func (m *Mapper) Execute(ctx context.Context) error

func (m *Mapper) Find(name string) Task

func (m *Mapper) Register(task Task) error

Register 注册

func (m *Mapper) Run(ctx context.Context, name string) error

func (m *Mapper) Tasks() map[string]Task

type Task interface {
	Name() string
	FlagSet(fg *flag.FlagSet)
	Run(ctx context.Context) error
	TearDown(err error)
}

Task 任务

type TaskHelper struct {
}

TaskHelper task 的一些辅助功能

func (h *TaskHelper) ConfDir() string

ConfDir 返回任务的配置目录

func (h *TaskHelper) DataDir() string

func (h *TaskHelper) ReadConf(name string, value any) error

ReadConf 从 task 自己的目录里解析配置

func (h *TaskHelper) TmpDir() string

Path	Synopsis
_example