taskgroup

Documentation

Index

• type Container
  • func NewContainer(ctx context.Context, conf *config.JSON) (c *Container, err error)
  • func (c *Container) Do() error
  • func (c *Container) JobID() int64
  • func (c *Container) Start() (err error)
  • func (c *Container) TaskGroupID() int64
• type Stats

Types

type Container

type Container struct {
	*core.BaseCotainer

	Err error
	// 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 任务组编号

type Stats

type Stats struct {
	TaskID  int64             `json:"taskID"`
	Channel channel.StatsJSON `json:"channel"`
}

Stats 统计信息