tracer

package
v1.1.69 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: May 17, 2024 License: MIT Imports: 26 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func BuildAttribute added in v1.0.46

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

func BuildBaggage added in v1.0.40

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

func ExtractTextMapCarrier

func ExtractTextMapCarrier(spanCtx context.Context) propagation.MapCarrier

func ExtractTextMapCarrierBytes

func ExtractTextMapCarrierBytes(spanCtx context.Context) []byte

func GetKafkaTracingHeadersFromSpanCtx added in v1.1.16

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

func InjectTextHeaderCarrier added in v1.1.18

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

func InjectTextMapCarrier

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

func MetricCount added in v1.0.38

func MetricCount(ctx context.Context, meter metric.Meter, data ...any)

func MetricLatency added in v1.0.38

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

func MetricLineCount added in v1.0.38

func MetricLineCount(ctx context.Context, meter metric.Meter, data ...any)

func NewTracer

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

func SetHttpAttributes added in v1.0.92

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

func StartAndTrace added in v1.0.39

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

func StartAndTraceHttp added in v1.0.40

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

func StartAndTraceKafkaConsumer added in v1.1.42

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

func StartAndTracePubsub added in v1.0.40

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

func StartAndTraceWithData added in v1.0.40

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

func StartSpan added in v1.1.0

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

func TextMapCarrierFromKafkaMessageHeaders added in v1.1.33

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

func TextMapCarrierToKafkaMessageHeaders added in v1.1.16

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

func TraceErr

func TraceErr(ctx context.Context, err error)

func TraceWithErr

func TraceWithErr(ctx context.Context, err error) error

Types

type IPgxTracer added in v1.1.13

type IPgxTracer interface {
	TraceQueryStart(ctx context.Context, conn *pgx.Conn, data pgx.TraceQueryStartData) context.Context

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

type PgxTracer added in v1.1.13

type PgxTracer struct {
}

func (*PgxTracer) TraceQueryEnd added in v1.1.13

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

func (*PgxTracer) TraceQueryStart added in v1.1.13

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL