type go.pact.im/x/process.Runner
27 uses
go.pact.im/x/process (current package)
chain.go#L9: func Chain(deps ...Runner) Runner {
chain.go#L20: deps []Runner
chain.go#L30: deps []Runner // len(deps) >= 2
parallel.go#L22: func Parallel(deps ...Runner) Runner {
parallel.go#L37: func Sequential(deps ...Runner) Runner {
parallel.go#L51: deps []Runner
process.go#L48: runner Runner
process.go#L63: func NewProcess(ctx context.Context, runner Runner) *Process {
runner.go#L19: type Runner interface {
runner.go#L47: func Nop() Runner {
runner.go#L59: runner Runner
runner.go#L65: func PrefixedError(prefix string, runner Runner) Runner {
task.go#L66: func Leaf(runInForeground, gracefulStop func(ctx context.Context) error) Runner {
task.go#L115: func StartStop(startInBackground, gracefulStop func(ctx context.Context) error) Runner {
go.pact.im/x/grpcprocess
grpcprocess.go#L15: func Server(srv *grpc.Server, lis net.Listener) process.Runner {
go.pact.im/x/httpprocess
httpprocess.go#L17: func Server(srv *http.Server, lis net.Listener) process.Runner {
go.pact.im/x/supervisor
builder.go#L12: type BuilderFunc[T process.Runner] func(context.Context) (T, error)
builder.go#L15: func Identity[T process.Runner](runner T) BuilderFunc[T] {
builder.go#L35: type Builder[T process.Runner] struct {
builder.go#L45: func NewBuilder[T process.Runner](f BuilderFunc[T]) *Builder[T] {
group.go#L68: func (g *Group) Go(p process.Runner, atExit func(error)) {
supervisor.go#L26: runner process.Runner
supervisor.go#L48: func NewSupervisor(runner process.Runner, exec flaky.Executor, hook Hook) *Supervisor {