parallel

Documentation

Index

• type Action
  • func (a *Action) Execute(ctx context.Context, runData runtime.Data) (bool, error)
  • func (a *Action) Timeout() time.Duration
  • func (a *Action) When() action.When
• type ActionMaker
  • func CreateActionMaker(fnd app.Foundation, runtimeMaker runtime.Maker) *ActionMaker
  • func (m *ActionMaker) Make(config *types.ParallelAction, sl services.ServiceLocator, defaultTimeout int, ...) (action.Action, error)
• type Maker

Types

type Action

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

func (*Action) Execute

func (a *Action) Execute(ctx context.Context, runData runtime.Data) (bool, error)

func (*Action) Timeout

func (a *Action) Timeout() time.Duration

func (*Action) When

func (a *Action) When() action.When

type ActionMaker

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

func CreateActionMaker

func CreateActionMaker(fnd app.Foundation, runtimeMaker runtime.Maker) *ActionMaker

func (*ActionMaker) Make

func (m *ActionMaker) Make(
	config *types.ParallelAction,
	sl services.ServiceLocator,
	defaultTimeout int,
	actionMaker action.Maker,
) (action.Action, error)

type Maker

type Maker interface {
	Make(
		config *types.ParallelAction,
		sl services.ServiceLocator,
		defaultTimeout int,
		actionMaker action.Maker,
	) (action.Action, error)
}