taskgroup

package

v0.1.0 Latest Latest Go to latest Published: Dec 13, 2022 License: Apache-2.0 Imports: 19 Imported by: 4

Details

This section is empty.

This section is empty.

This section is empty.

type Container struct {
	*core.BaseCotainer

	Err error
	// contains filtered or unexported fields
}

Container 任务组容器环境

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

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

func (c *Container) Do() error

Do 执行

func (c *Container) JobID() int64

JobID 工作编号

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

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

func (c *Container) TaskGroupID() int64

TaskGroupID 任务组编号

Path	Synopsis
runner