tracer

package

v1.1.67 Latest Latest Go to latest Published: Feb 25, 2024 License: MIT Imports: 26 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/dispenal/go-common

Links

Open Source Insights

Documentation ¶

Index ¶

func BuildAttribute(args ...any) []attribute.KeyValue
func BuildBaggage(args ...any) baggage.Baggage
func ExtractTextMapCarrier(spanCtx context.Context) propagation.MapCarrier
func ExtractTextMapCarrierBytes(spanCtx context.Context) []byte
func GetKafkaTracingHeadersFromSpanCtx(spanCtx context.Context) []kafka.Header
func InjectTextHeaderCarrier(spanCtx context.Context) (propagation.HeaderCarrier, error)
func InjectTextMapCarrier(spanCtx context.Context) (propagation.MapCarrier, error)
func MetricCount(ctx context.Context, meter metric.Meter, data ...any)
func MetricLatency(ctx context.Context, span trace.Span, meter metric.Meter, data ...any)
func MetricLineCount(ctx context.Context, meter metric.Meter, data ...any)
func NewTracer(baseConfig *common_utils.BaseConfig) func()
func SetHttpAttributes(span trace.Span, r *http.Request)
func StartAndTrace(ctx context.Context, spanName string) (context.Context, trace.Span)
func StartAndTraceHttp(r *http.Request, spanName string) (context.Context, trace.Span)
func StartAndTraceKafkaConsumer(ctx context.Context, headers propagation.MapCarrier, spanName string) (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)
func StartSpan(ctx context.Context) (context.Context, trace.Span)
func TextMapCarrierFromKafkaMessageHeaders(headers []kafka.Header) propagation.MapCarrier
func TextMapCarrierToKafkaMessageHeaders(textMap propagation.MapCarrier) []kafka.Header
func TraceErr(ctx context.Context, err error)
func TraceWithErr(ctx context.Context, err error) error
type IPgxTracer
type PgxTracer
- 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

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

Source Files ¶

View all Source files

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