wait

Documentation

Index

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

Types

type WaitExecutor

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

func NewWaitExecutor

func NewWaitExecutor(logger zerolog.Logger) *WaitExecutor

func (*WaitExecutor) Execute

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