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()
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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
Source Files
Click to show internal directories.
Click to hide internal directories.