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 represents the environment for a group of tasks.

func NewContainer

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

NewContainer creates a task group container based on the JSON configuration conf. If jobID or taskGroupID is invalid, an error will be reported.

func (*Container) Do

func (c *Container) Do() error

Do represents the execution action.

func (*Container) JobID

func (c *Container) JobID() int64

JobID refers to the unique identifier for a job.

func (*Container) Start

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

Start initiates the execution of tasks using the task scheduler based on the JSON configurations.

func (*Container) TaskGroupID

func (c *Container) TaskGroupID() int64

TaskGroupID refers to the unique identifier for a group of tasks.

type Stats

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

Stats - Information or metrics related to the task's execution