spawn

Documentation

Index

• func Inject[T target.Portal_](deps Deps[T]) target.Dispatch
• type Deps
• type Runner
  • func NewRunner[T target.Portal_](wait *sync.WaitGroup, processes *sig.Map[string, T], find target.Find[T], ...) *Runner[T]
  • func (r *Runner[T]) Run(ctx context.Context, src string, args ...string) (err error)

Functions

func Inject

func Inject[T target.Portal_](deps Deps[T]) target.Dispatch

Types

type Deps

type Deps[T target.Portal_] interface {
	WaitGroup() *sync.WaitGroup
	Processes() *sig.Map[string, T]
	TargetFind() target.Find[T]
	TargetRun() target.Run[T]
}

type Runner

type Runner[T target.Portal_] struct {
	// contains filtered or unexported fields
}

func NewRunner

func NewRunner[T target.Portal_](
	wait *sync.WaitGroup,
	processes *sig.Map[string, T],
	find target.Find[T],
	run target.Run[T],
) *Runner[T]

func (*Runner[T]) Run

func (r *Runner[T]) Run(ctx context.Context, src string, args ...string) (err error)