executor

Documentation

Index

• func ExecuteCommandFuncFromInputsMap(cmdFunc interface{}, inputs map[string]interface{}) (interface{}, error)
• type ServiceExecutor
  • func NewServiceExecutor(service service.Service, updateChannel chan<- *service.UpdateService) *ServiceExecutor
  • func (se *ServiceExecutor) Execute() (err error)
  • func (se *ServiceExecutor) SendServiceStatusUpdate(seq int, status service.StepStatus, result service.Result, st, et time.Time)
• type StepExecutor
  • func NewStepExecutor(step *flow.CommandStep) (*StepExecutor, error)
  • func (se *StepExecutor) Execute() (interface{}, error)

Functions

func ExecuteCommandFuncFromInputsMap

func ExecuteCommandFuncFromInputsMap(cmdFunc interface{}, inputs map[string]interface{}) (interface{}, error)

Types

type ServiceExecutor

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

func NewServiceExecutor

func NewServiceExecutor(service service.Service, updateChannel chan<- *service.UpdateService) *ServiceExecutor

func (*ServiceExecutor) Execute

func (se *ServiceExecutor) Execute() (err error)

func (*ServiceExecutor) SendServiceStatusUpdate

func (se *ServiceExecutor) SendServiceStatusUpdate(seq int, status service.StepStatus, result service.Result, st, et time.Time)

type StepExecutor

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

func NewStepExecutor

func NewStepExecutor(step *flow.CommandStep) (*StepExecutor, error)

func (*StepExecutor) Execute

func (se *StepExecutor) Execute() (interface{}, error)