worker

package

v1.1.2 Latest Latest Go to latest Published: Jan 3, 2024 License: GPL-3.0 Imports: 18 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

Repository

github.com/xmapst/osreapi

Documentation ¶

Constants ¶

View Source

const ConsoleDone = "OSREAPI::CONSOLE::DONE"

View Source

const ConsoleStart = "OSREAPI::CONSOLE::START"

Variables ¶

View Source

var (
	// DefaultSize 默认worker数为cpu核心数的两倍
	DefaultSize = runtime.NumCPU() * 2
)

Functions ¶

func GetSize ¶

func GetSize() int

func GetTotal ¶ added in v1.0.10

func GetTotal() int64

func Running ¶

func Running() int64

func SetSize ¶

func SetSize(n int)

func StopWait ¶

func StopWait()

func Submit ¶

func Submit(task *Task) error

func Waiting ¶

func Waiting() int64

Types ¶

type Task ¶

type Task struct {
	ID       string
	Timeout  time.Duration
	MetaData types.MetaData
	Steps    []*TaskStep
	// contains filtered or unexported fields
}

type TaskStep ¶

type TaskStep struct {
	ID             string
	CommandType    string
	CommandContent string
	EnvVars        []string
	DependsOn      []string
	Timeout        time.Duration
}

Source Files ¶

View all Source files

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