taskrunner

Documentation

Index

• type Runner
  • func (r *Runner) ActiveWorkers() int
  • func (r *Runner) Execute(ctx context.Context, l logr.Logger, description, taskID string, ...)
  • func (r *Runner) Status(_ context.Context, taskID string) (record repository.Record, err error)
  • func (r *Runner) TotalWorkers() int

Types

type Runner

type Runner struct {
	Repository repository.Actions
	Ctx        context.Context
	// contains filtered or unexported fields
}

Runner for executing a task.

func (*Runner) ActiveWorkers

func (r *Runner) ActiveWorkers() int

ActiveWorkers returns a count of currently active worker jobs.

func (*Runner) Execute

func (r *Runner) Execute(ctx context.Context, l logr.Logger, description, taskID string, action func(chan string) (string, error))

Execute a task, update repository with status.

func (*Runner) Status

func (r *Runner) Status(_ context.Context, taskID string) (record repository.Record, err error)

Status returns the status record of a task.

func (*Runner) TotalWorkers

func (r *Runner) TotalWorkers() int

TotalWorkers returns a count total workers executed.