tracenode

Documentation

Index

• Constants
• func BuildTraceParentId(traceID [16]byte, spanID [8]byte) string
• func ExtractStrategy(ctx api.StreamContext) topoContext.TraceStrategy
• func RecordRowOrCollection(input interface{}, span trace.Span)
• func StartTraceBackground(ctx api.StreamContext, opName string, opts ...trace.SpanStartOption) (bool, api.StreamContext, trace.Span)
• func StartTraceByID(ctx api.StreamContext, parentId string, opts ...trace.SpanStartOption) (bool, api.StreamContext, trace.Span)
• func ToStringCollection(r api.MessageTupleList) string
• func ToStringRow(r xsql.Row) string
• func TraceInput(ctx api.StreamContext, d any, opName string, opts ...trace.SpanStartOption) (bool, api.StreamContext, trace.Span)

Constants

const (
	DataKey = "data"
	RuleKey = "rule"
)

Functions

func BuildTraceParentId

func BuildTraceParentId(traceID [16]byte, spanID [8]byte) string

func ExtractStrategy

func ExtractStrategy(ctx api.StreamContext) topoContext.TraceStrategy

func RecordRowOrCollection

func RecordRowOrCollection(input interface{}, span trace.Span)

func StartTraceBackground

func StartTraceBackground(ctx api.StreamContext, opName string, opts ...trace.SpanStartOption) (bool, api.StreamContext, trace.Span)

func StartTraceByID

func StartTraceByID(ctx api.StreamContext, parentId string, opts ...trace.SpanStartOption) (bool, api.StreamContext, trace.Span)

func ToStringCollection

func ToStringCollection(r api.MessageTupleList) string

func ToStringRow

func ToStringRow(r xsql.Row) string

func TraceInput

func TraceInput(ctx api.StreamContext, d any, opName string, opts ...trace.SpanStartOption) (bool, api.StreamContext, trace.Span)