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
- 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)
Constants ¶
This section is empty.
Variables ¶
View Source
var GlobalConfig *utils.OpenTracingConfig
View Source
var GlobalTracer opentracing.Tracer
Functions ¶
This section is empty.
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
Source Files
Click to show internal directories.
Click to hide internal directories.