pass

Documentation

Index

• type PassExecutor
  • func NewPassExecutorr(logger zerolog.Logger) *PassExecutor
  • func (executor *PassExecutor) Execute(context message.Context, input interface{}, taskConfig *model.Task) (interface{}, *model.Task, errors.Error)

Types

type PassExecutor

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

func NewPassExecutorr

func NewPassExecutorr(logger zerolog.Logger) *PassExecutor

func (*PassExecutor) Execute

func (executor *PassExecutor) Execute(context message.Context, input interface{}, taskConfig *model.Task) (interface{}, *model.Task, errors.Error)