taskgroup

package

v0.2.0 Latest Latest Go to latest Published: Aug 16, 2024 License: Apache-2.0 Imports: 20 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 represents the environment for a group of tasks.

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 (c *Container) Do() error

Do represents the execution action.

func (c *Container) JobID() int64

JobID refers to the unique identifier for a job.

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

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

func (c *Container) TaskGroupID() int64

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

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

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

Path	Synopsis
runner