behaviors

Documentation

Index

• Variables
• type OpenTracingFlow
  • func (fb *OpenTracingFlow) Done(ctx model.FlowContext)
  • func (fb *OpenTracingFlow) Resume(ctx model.FlowContext) (resumed bool)
  • func (fb *OpenTracingFlow) Start(ctx model.FlowContext) (started bool, taskEntries []*model.TaskEntry)
  • func (fb *OpenTracingFlow) StartErrorHandler(ctx model.FlowContext) (taskEntries []*model.TaskEntry)
  • func (fb *OpenTracingFlow) TaskDone(ctx model.FlowContext) (flowDone bool)
• type OpenTracingIteratorTask
  • func (tb *OpenTracingIteratorTask) Eval(ctx model.TaskContext) (evalResult model.EvalResult, err error)
  • func (tb *OpenTracingIteratorTask) PostEval(ctx model.TaskContext) (evalResult model.EvalResult, err error)
• type OpenTracingTask
  • func (tb *OpenTracingTask) Done(ctx model.TaskContext) (notifyFlow bool, taskEntries []*model.TaskEntry, err error)
  • func (tb *OpenTracingTask) Enter(ctx model.TaskContext) (enterResult model.EnterResult)
  • func (tb *OpenTracingTask) Error(ctx model.TaskContext, err error) (handled bool, taskEntries []*model.TaskEntry)
  • func (tb *OpenTracingTask) Eval(ctx model.TaskContext) (evalResult model.EvalResult, err error)
  • func (tb *OpenTracingTask) PostEval(ctx model.TaskContext) (evalResult model.EvalResult, err error)
  • func (tb *OpenTracingTask) Skip(ctx model.TaskContext) (notifyFlow bool, taskEntries []*model.TaskEntry)

Variables

var GlobalConfig *utils.OpenTracingConfig

var GlobalTracer opentracing.Tracer

Types

type OpenTracingFlow

type OpenTracingFlow struct {
}

OpenTracingFlow implements model.FlowBehavior

func (*OpenTracingFlow) Done

func (fb *OpenTracingFlow) Done(ctx model.FlowContext)

Done implements model.Flow.Done

func (*OpenTracingFlow) Resume

func (fb *OpenTracingFlow) Resume(ctx model.FlowContext) (resumed bool)

Resume implements model.Flow.Resume

func (*OpenTracingFlow) Start

func (fb *OpenTracingFlow) Start(ctx model.FlowContext) (started bool, taskEntries []*model.TaskEntry)

Start implements model.Flow.Start

func (*OpenTracingFlow) StartErrorHandler

func (fb *OpenTracingFlow) StartErrorHandler(ctx model.FlowContext) (taskEntries []*model.TaskEntry)

StartErrorHandler implements model.Flow.StartErrorHandler

func (*OpenTracingFlow) TaskDone

func (fb *OpenTracingFlow) TaskDone(ctx model.FlowContext) (flowDone bool)

TasksDone implements model.Flow.TasksDone

type OpenTracingIteratorTask

type OpenTracingIteratorTask struct {
	OpenTracingTask
}

OpenTracingIteratorTask implements model.TaskBehavior

func (*OpenTracingIteratorTask) Eval

func (tb *OpenTracingIteratorTask) Eval(ctx model.TaskContext) (evalResult model.EvalResult, err error)

Eval implements model.TaskBehavior.Eval

func (*OpenTracingIteratorTask) PostEval

func (tb *OpenTracingIteratorTask) PostEval(ctx model.TaskContext) (evalResult model.EvalResult, err error)

PostEval implements model.TaskBehavior.PostEval

type OpenTracingTask

type OpenTracingTask struct {
}

func (*OpenTracingTask) Done

func (tb *OpenTracingTask) Done(ctx model.TaskContext) (notifyFlow bool, taskEntries []*model.TaskEntry, err error)

Done implements model.Task.Done

func (*OpenTracingTask) Enter

func (tb *OpenTracingTask) Enter(ctx model.TaskContext) (enterResult model.EnterResult)

Enter implements model.Task.Enter

func (*OpenTracingTask) Error

func (tb *OpenTracingTask) Error(ctx model.TaskContext, err error) (handled bool, taskEntries []*model.TaskEntry)

Done implements model.Task.Error

func (*OpenTracingTask) Eval

func (tb *OpenTracingTask) Eval(ctx model.TaskContext) (evalResult model.EvalResult, err error)

Eval implements model.Task.Eval

func (*OpenTracingTask) PostEval

func (tb *OpenTracingTask) PostEval(ctx model.TaskContext) (evalResult model.EvalResult, err error)

PostEval implements model.Task.PostEval

func (*OpenTracingTask) Skip

func (tb *OpenTracingTask) Skip(ctx model.TaskContext) (notifyFlow bool, taskEntries []*model.TaskEntry)

Done implements model.Task.Skip