type go.pact.im/x/process.Runnable
22 uses
go.pact.im/x/process (current package)
chain.go#L9: func Chain(deps ...Runnable) Runnable {
chain.go#L20: deps []Runnable
chain.go#L30: deps []Runnable // len(deps) >= 2
parallel.go#L22: func Parallel(deps ...Runnable) Runnable {
parallel.go#L37: func Sequential(deps ...Runnable) Runnable {
parallel.go#L51: deps []Runnable
process.go#L49: proc Runnable
process.go#L64: func NewProcess(ctx context.Context, proc Runnable) *Process {
runnable.go#L20: type Runnable interface {
runnable.go#L47: func Nop() Runnable {
runnable.go#L59: proc Runnable
runnable.go#L64: func Named(name string, p Runnable) Runnable {
task.go#L66: func Leaf(runInForeground, gracefulStop func(ctx context.Context) error) Runnable {
task.go#L115: func StartStop(startInBackground, gracefulStop func(ctx context.Context) error) Runnable {
go.pact.im/x/grpcprocess
grpcprocess.go#L14: func Server(srv *grpc.Server, lis net.Listener) process.Runnable {
go.pact.im/x/supervisor
supervisor.go#L19: type Supervisor[K comparable, P process.Runnable] struct {
supervisor.go#L48: type managedProcess[P process.Runnable] struct {
supervisor.go#L76: func NewSupervisor[K comparable, P process.Runnable](t Table[K, P], o Options) *Supervisor[K, P] {