eventhandler

Documentation

Index

• type GoFlowEventHandler
  • func (eh *GoFlowEventHandler) Configure(flowName string, requestID string)
  • func (eh *GoFlowEventHandler) Flush()
  • func (eh *GoFlowEventHandler) Init() error
  • func (eh *GoFlowEventHandler) ReportExecutionContinuation(requestID string)
  • func (eh *GoFlowEventHandler) ReportExecutionForward(currentNodeID string, requestID string)
  • func (eh *GoFlowEventHandler) ReportNodeEnd(nodeID string, requestID string)
  • func (eh *GoFlowEventHandler) ReportNodeFailure(nodeID string, requestID string, err error)
  • func (eh *GoFlowEventHandler) ReportNodeStart(nodeID string, requestID string)
  • func (eh *GoFlowEventHandler) ReportOperationEnd(operationID string, nodeID string, requestID string)
  • func (eh *GoFlowEventHandler) ReportOperationFailure(operationID string, nodeID string, requestID string, err error)
  • func (eh *GoFlowEventHandler) ReportOperationStart(operationID string, nodeID string, requestID string)
  • func (eh *GoFlowEventHandler) ReportRequestEnd(requestID string)
  • func (eh *GoFlowEventHandler) ReportRequestFailure(requestID string, err error)
  • func (eh *GoFlowEventHandler) ReportRequestStart(requestID string)
• type TraceHandler
  • func (tracerObj *TraceHandler) ContinueReqSpan(reqID string, header map[string][]string)
  • func (tracerObj *TraceHandler) ExtendReqSpan(reqID string, lastNode string, url string, req *runtime.Request)
  • func (tracerObj *TraceHandler) FlushTracer()
  • func (tracerObj *TraceHandler) StartNodeSpan(node string, reqID string)
  • func (tracerObj *TraceHandler) StartOperationSpan(node string, reqID string, operationID string)
  • func (tracerObj *TraceHandler) StartReqSpan(reqID string)
  • func (tracerObj *TraceHandler) StopNodeSpan(node string)
  • func (tracerObj *TraceHandler) StopOperationSpan(node string, operationID string)
  • func (tracerObj *TraceHandler) StopReqSpan()

Types

type GoFlowEventHandler

type GoFlowEventHandler struct {
	CurrentNodeID string        // used to inject current node id in Tracer
	Tracer        *TraceHandler // handle traces with open-tracing

	TraceURI string
	Header   map[string][]string
	// contains filtered or unexported fields
}

implements core.EventHandler

func (*GoFlowEventHandler) Configure

func (eh *GoFlowEventHandler) Configure(flowName string, requestID string)

func (*GoFlowEventHandler) Flush

func (eh *GoFlowEventHandler) Flush()

func (*GoFlowEventHandler) Init

func (eh *GoFlowEventHandler) Init() error

func (*GoFlowEventHandler) ReportExecutionContinuation

func (eh *GoFlowEventHandler) ReportExecutionContinuation(requestID string)

func (*GoFlowEventHandler) ReportExecutionForward

func (eh *GoFlowEventHandler) ReportExecutionForward(currentNodeID string, requestID string)

func (*GoFlowEventHandler) ReportNodeEnd

func (eh *GoFlowEventHandler) ReportNodeEnd(nodeID string, requestID string)

func (*GoFlowEventHandler) ReportNodeFailure

func (eh *GoFlowEventHandler) ReportNodeFailure(nodeID string, requestID string, err error)

func (*GoFlowEventHandler) ReportNodeStart

func (eh *GoFlowEventHandler) ReportNodeStart(nodeID string, requestID string)

func (*GoFlowEventHandler) ReportOperationEnd

func (eh *GoFlowEventHandler) ReportOperationEnd(operationID string, nodeID string, requestID string)

func (*GoFlowEventHandler) ReportOperationFailure

func (eh *GoFlowEventHandler) ReportOperationFailure(operationID string, nodeID string, requestID string, err error)

func (*GoFlowEventHandler) ReportOperationStart

func (eh *GoFlowEventHandler) ReportOperationStart(operationID string, nodeID string, requestID string)

func (*GoFlowEventHandler) ReportRequestEnd

func (eh *GoFlowEventHandler) ReportRequestEnd(requestID string)

func (*GoFlowEventHandler) ReportRequestFailure

func (eh *GoFlowEventHandler) ReportRequestFailure(requestID string, err error)

func (*GoFlowEventHandler) ReportRequestStart

func (eh *GoFlowEventHandler) ReportRequestStart(requestID string)

type TraceHandler

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

func (*TraceHandler) ContinueReqSpan

func (tracerObj *TraceHandler) ContinueReqSpan(reqID string, header map[string][]string)

ContinueReqSpan continue request span

func (*TraceHandler) ExtendReqSpan

func (tracerObj *TraceHandler) ExtendReqSpan(reqID string, lastNode string, url string, req *runtime.Request)

ExtendReqSpan extend req span over a request func ExtendReqSpan(url string, req *http.Request) {

func (*TraceHandler) FlushTracer

func (tracerObj *TraceHandler) FlushTracer()

FlushTracer flush all pending traces

func (*TraceHandler) StartNodeSpan

func (tracerObj *TraceHandler) StartNodeSpan(node string, reqID string)

StartNodeSpan starts a node span

func (*TraceHandler) StartOperationSpan

func (tracerObj *TraceHandler) StartOperationSpan(node string, reqID string, operationID string)

StartOperationSpan starts an operation span

func (*TraceHandler) StartReqSpan

func (tracerObj *TraceHandler) StartReqSpan(reqID string)

StartReqSpan starts a request span

func (*TraceHandler) StopNodeSpan

func (tracerObj *TraceHandler) StopNodeSpan(node string)

StopNodeSpan terminates a node span

func (*TraceHandler) StopOperationSpan

func (tracerObj *TraceHandler) StopOperationSpan(node string, operationID string)

StopOperationSpan stops an operation span

func (*TraceHandler) StopReqSpan

func (tracerObj *TraceHandler) StopReqSpan()

StopReqSpan terminate a request span