tracing

Documentation

Index

• Constants
• func GetTextMapCarrierFromEvent(event eventstore.Event) opentracing.TextMapCarrier
• func GetTextMapCarrierFromMetaData(ctx context.Context) opentracing.TextMapCarrier
• func InjectSpanContextIntoGrpcMetadata(ctx context.Context, span opentracing.Span) context.Context
• func LogObjectAsJson(span opentracing.Span, name string, object any)
• func SetCommandHandlerSpanTags(ctx context.Context, span opentracing.Span, tenant, userId string)
• func SetNeo4jRepositorySpanTags(ctx context.Context, span opentracing.Span, tenant string)
• func SetServiceSpanTags(ctx context.Context, span opentracing.Span, tenant, loggedInUserId string)
• func StartGrpcServerTracerSpan(ctx context.Context, operationName string) (context.Context, opentracing.Span)
• func StartProjectionTracerSpan(ctx context.Context, operationName string, event eventstore.Event) (context.Context, opentracing.Span)
• func TraceErr(span opentracing.Span, err error, fields ...log.Field)

Constants

const (
	SpanTagTenant                = "tenant"
	SpanTagUserId                = "user-id"
	SpanTagComponent             = "component"
	SpanTagAggregateId           = "aggregateID"
	SpanTagEntityId              = "entity-id"
	SpanTagRedundantEventSkipped = "redundantEventSkipped"
)

Functions

func GetTextMapCarrierFromEvent

func GetTextMapCarrierFromEvent(event eventstore.Event) opentracing.TextMapCarrier

func GetTextMapCarrierFromMetaData

func GetTextMapCarrierFromMetaData(ctx context.Context) opentracing.TextMapCarrier

func InjectSpanContextIntoGrpcMetadata

func InjectSpanContextIntoGrpcMetadata(ctx context.Context, span opentracing.Span) context.Context

func LogObjectAsJson

func LogObjectAsJson(span opentracing.Span, name string, object any)

func SetCommandHandlerSpanTags

func SetCommandHandlerSpanTags(ctx context.Context, span opentracing.Span, tenant, userId string)

func SetNeo4jRepositorySpanTags

func SetNeo4jRepositorySpanTags(ctx context.Context, span opentracing.Span, tenant string)

func SetServiceSpanTags

func SetServiceSpanTags(ctx context.Context, span opentracing.Span, tenant, loggedInUserId string)

func StartGrpcServerTracerSpan

func StartGrpcServerTracerSpan(ctx context.Context, operationName string) (context.Context, opentracing.Span)

func StartProjectionTracerSpan

func StartProjectionTracerSpan(ctx context.Context, operationName string, event eventstore.Event) (context.Context, opentracing.Span)

func TraceErr

func TraceErr(span opentracing.Span, err error, fields ...log.Field)