tasker

package module
v0.0.6 Latest Latest
Warning

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

 Go to latest Published: Jun 6, 2023 License: MIT Imports: 2 Imported by: 3

README

gotasker

Documentation

Overview

Package godler provides ...

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func ExecTasker added in v0.0.4 

func ExecTasker(t ITasker, isSync bool) error

执行任务

func GetTaskerProgress added in v0.0.6 

func GetTaskerProgress(t ITasker) (p float64, err error)

获取任务进度 建议 NewTask 方法精确的传入 done 参数

func SimpleExecTasks added in v0.0.6 

func SimpleExecTasks(tasks []*Task, runFunc TaskFunc) error

Types

type ITasker 

type ITasker interface {
	Build() error
	BuildTasks() error
	AddTask(*Task)
	GetTasks() []*Task
	RunTask(*Task) error
	Run(TaskFunc) error
	SyncRun(TaskFunc) error
	AfterRun() error
	BeforeRun() error
	Progress() float64
}

type Task 

type Task struct {
	RetryTime int         `json:"retry_count"`
	Err       error       `json:"err"`
	IsDone    bool        `json:"done"`
	Info      interface{} `json:"info"`
}

func NewTask added in v0.0.6 

func NewTask(info interface{}, done bool) *Task

新建任务体 info: 具体的任务 done: 该任务是否已经完成，正确的传入此值可以提升效率

func (*Task) Done added in v0.0.6 

func (t *Task) Done() *Task

type TaskFunc 

type TaskFunc func(*Task) error

type Tasker 

type Tasker struct {
	TaskId string
	Config *TaskerConfig
	// contains filtered or unexported fields
}

func NewTasker 

func NewTasker() *Tasker

func (*Tasker) AddTask 

func (t *Tasker) AddTask(task *Task)

func (*Tasker) AfterRun 

func (t *Tasker) AfterRun() error

func (*Tasker) BeforeRun 

func (t *Tasker) BeforeRun() error

func (*Tasker) Build 

func (t *Tasker) Build() error

func (*Tasker) BuildTasks 

func (t *Tasker) BuildTasks() error

func (*Tasker) GetErrorTasks added in v0.0.3 

func (t *Tasker) GetErrorTasks() []*Task

func (*Tasker) GetTasks 

func (t *Tasker) GetTasks() []*Task

func (*Tasker) Progress added in v0.0.6 

func (t *Tasker) Progress() float64

获取进度

func (*Tasker) Run 

func (t *Tasker) Run(runTaskFunc TaskFunc) error

func (*Tasker) RunTask 

func (t *Tasker) RunTask(task *Task) error

func (*Tasker) SyncRun 

func (t *Tasker) SyncRun(runTaskFunc TaskFunc) error

type TaskerConfig 

type TaskerConfig struct {
	ProcessNum     int
	RetryMaxTime   int
	UseProgressBar bool
}

func NewTaskerConfig 

func NewTaskerConfig() *TaskerConfig

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.