external

Documentation

Index

• func Run(ctx *neighbor.Ctx, in <-chan github.ExternalProject) <-chan github.ExternalProject

Functions

func Run

func Run(ctx *neighbor.Ctx, in <-chan github.ExternalProject) <-chan github.ExternalProject

Run runs an arbitrary command specified in the Ctx on each project that is sent through the pipeline.

The number of workers is defined by the number of logical CPUs that read from the pipeline and then run the external command on each project.

When each worker has recieved the empty channel signal from the pipeline, we are finished.