tracer

Dec 22, 2023

Changes in this version

+ func StartAndTraceKafkaConsumer(ctx context.Context, headers propagation.MapCarrier, spanName string) (context.Context, trace.Span)

Dec 21, 2023

Changes in this version

+ func StartKafkaConsumerTracerSpan(ctx context.Context, headers []kafka.Header, spanName string) (context.Context, trace.Span)

+ func TextMapCarrierFromKafkaMessageHeaders(headers []kafka.Header) propagation.MapCarrier

Dec 18, 2023

Changes in this version

+ func InjectTextHeaderCarrier(spanCtx context.Context) (propagation.HeaderCarrier, error)

+ func TextHeaderCarrierToKafkaMessageHeaders(hederMap propagation.HeaderCarrier) []kafka.Header

Dec 18, 2023

Changes in this version

+ func GetKafkaTracingHeadersFromSpanCtx(spanCtx context.Context) []kafka.Header

+ func TextMapCarrierToKafkaMessageHeaders(textMap propagation.MapCarrier) []kafka.Header

Dec 18, 2023

Changes in this version

+ type IPgxTracer interface

+ TraceQueryEnd func(ctx context.Context, conn *pgx.Conn, data pgx.TraceQueryEndData)

+ TraceQueryStart func(ctx context.Context, conn *pgx.Conn, data pgx.TraceQueryStartData) context.Context

+ type PgxTracer struct

+ func (t *PgxTracer) TraceQueryEnd(ctx context.Context, conn *pgx.Conn, data pgx.TraceQueryEndData)

+ func (t *PgxTracer) TraceQueryStart(ctx context.Context, conn *pgx.Conn, data pgx.TraceQueryStartData) context.Context

Dec 14, 2023

Changes in this version

+ func StartSpan(ctx context.Context) (context.Context, trace.Span)

Dec 14, 2023

Changes in this version

+ func SetHttpAttributes(span trace.Span, r *http.Request)

Dec 13, 2023

Changes in this version

+ func BuildAttribute(args ...any) []attribute.KeyValue

Dec 13, 2023

Changes in this version

+ func BuildBaggage(args ...any) baggage.Baggage

+ func StartAndTraceHttp(ctx context.Context, spanName string, r *http.Request) (context.Context, trace.Span)

+ func StartAndTracePubsub(ctx context.Context, spanName string, data *pubsub.Message) (context.Context, trace.Span)

+ func StartAndTraceWithData(ctx context.Context, spanName string, data ...any) (context.Context, trace.Span)

Dec 13, 2023

Changes in this version

+ func StartAndTrace(ctx context.Context, spanName string) (context.Context, trace.Span)

Dec 13, 2023

Changes in this version

+ func MetricCount(ctx context.Context, meter metric.Meter, attributes []attribute.KeyValue)

+ func MetricLatency(ctx context.Context, span trace.Span, meter metric.Meter, ...)

+ func MetricLineCount(ctx context.Context, meter metric.Meter, attributes []attribute.KeyValue)

Dec 13, 2023

Changes in this version

+ func ExtractTextMapCarrier(spanCtx context.Context) propagation.MapCarrier

+ func ExtractTextMapCarrierBytes(spanCtx context.Context) []byte

+ func InjectTextMapCarrier(spanCtx context.Context) (propagation.MapCarrier, error)

+ func NewTracer(baseConfig *common_utils.BaseConfig) func()

+ func TraceErr(span trace.Span, err error)

+ func TraceWithErr(span trace.Span, err error) error