concurrency

Documentation

Index

• Variables
• type Runner
• type RunnerManager
  • func NewRunnerManager(runners ...Runner) *RunnerManager
  • func (r *RunnerManager) Add(runner ...Runner) error
  • func (r *RunnerManager) Run(ctx context.Context) (err error)

Variables

var ErrManagerAlreadyStarted = errors.New("manager already started")

Types

type Runner

type Runner func(context.Context) error

Runner is a function that runs a task.

type RunnerManager

type RunnerManager struct {
	// contains filtered or unexported fields
}

RunnerManager is a manager for runners. It runs all runners in parallel and waits for all runners to finish. If any runner returns, the RunnerManager will stop all other runners and return any error.

func NewRunnerManager

func NewRunnerManager(runners ...Runner) *RunnerManager

NewRunnerManager creates a new RunnerManager.

func (*RunnerManager) Add

func (r *RunnerManager) Add(runner ...Runner) error

Add adds a new runner to the RunnerManager.

func (*RunnerManager) Run

func (r *RunnerManager) Run(ctx context.Context) (err error)

Run runs all runners in parallel and waits for all runners to finish. If any runner returns, the RunnerManager will stop all other runners and return any error.