sync

Documentation

Index

• type Pool
  • func NewPool(opts flags.RootPflagpole, popts flags.FlowPflagpole) *Pool
  • func (M *Pool) Apply(ctx *flowctx.Context, runner flowctx.RunnerFunc) flowctx.RunnerFunc
  • func (M *Pool) Run(ctx *flowctx.Context) (results interface{}, err error)
• type Wait
  • func NewWait(opts flags.RootPflagpole, popts flags.FlowPflagpole) *Wait
  • func (M *Wait) Apply(ctx *hofcontext.Context, runner hofcontext.RunnerFunc) hofcontext.RunnerFunc
  • func (M *Wait) Run(ctx *hofcontext.Context) (results interface{}, err error)

Types

type Pool

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

func NewPool

func NewPool(opts flags.RootPflagpole, popts flags.FlowPflagpole) *Pool

func (*Pool) Apply

func (M *Pool) Apply(ctx *flowctx.Context, runner flowctx.RunnerFunc) flowctx.RunnerFunc

func (*Pool) Run

func (M *Pool) Run(ctx *flowctx.Context) (results interface{}, err error)

type Wait

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

func NewWait

func NewWait(opts flags.RootPflagpole, popts flags.FlowPflagpole) *Wait

func (*Wait) Apply

func (M *Wait) Apply(ctx *hofcontext.Context, runner hofcontext.RunnerFunc) hofcontext.RunnerFunc

func (*Wait) Run

func (M *Wait) Run(ctx *hofcontext.Context) (results interface{}, err error)