taskgroup

package
Version: v0.0.0-...-1620968 Latest Latest
Warning

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

Go to latest
Published: Jun 17, 2021 License: Apache-2.0 Imports: 17 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Container

type Container struct {
	*core.BaseCotainer
	// contains filtered or unexported fields
}

Container 任务组容器环境

func NewContainer

func NewContainer(ctx context.Context, conf *config.JSON) (c *Container, err error)

NewContainer 根据JSON配置conf创建任务组容器 当jobID 和 taskGroupID非法就会报错

func (*Container) Do

func (c *Container) Do() error

Do 执行

func (*Container) JobID

func (c *Container) JobID() int64

JobID 工作编号

func (*Container) Start

func (c *Container) Start() (err error)

Start 开始运行,使用任务调度器执行这些JSON配置

func (*Container) TaskGroupID

func (c *Container) TaskGroupID() int64

TaskGroupID 任务组编号

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to