telemetry

Documentation

Index

• func AddOpenTelemetryToClient(httpClient *http.Client, meterProvider meter.MeterProvider, ...) *http.Client
• func AsyncRouteTagMiddleware(next http.Handler) http.Handler
• func ExtractContext(ctx context.Context, headers map[string]any) context.Context
• func InjectToAmqp(ctx context.Context, payload amqp.Publishing) amqp.Publishing
• func SetRouteTag(ctx context.Context, route string)
• type Config
  • func Flags(fs *flag.FlagSet, prefix string, overrides ...flags.Override) *Config
• type FinishSpan
  • func StartSpan(ctx context.Context, tracer tr.Tracer, name string, opts ...tr.SpanStartOption) (context.Context, FinishSpan)
• type OtlpLogger
  • func (tl OtlpLogger) Handle(ctx context.Context, r slog.Record) error
• type Service
  • func New(ctx context.Context, config *Config) (Service, error)
  • func (s Service) AddTraceToLogHandler(handler slog.Handler) slog.Handler
  • func (s Service) Close(ctx context.Context)
  • func (s Service) MeterProvider() meter.MeterProvider
  • func (s Service) Middleware(name string) func(next http.Handler) http.Handler
  • func (s Service) TracerProvider() tr.TracerProvider
• type SimpleHeaderCarrier
  • func (shc SimpleHeaderCarrier) Get(key string) string
  • func (shc SimpleHeaderCarrier) Keys() []string
  • func (shc SimpleHeaderCarrier) Set(key string, value string)

Functions

func AddOpenTelemetryToClient

func AddOpenTelemetryToClient(httpClient *http.Client, meterProvider meter.MeterProvider, tracerProvider tr.TracerProvider) *http.Client

func AsyncRouteTagMiddleware

func AsyncRouteTagMiddleware(next http.Handler) http.Handler

func ExtractContext

func ExtractContext(ctx context.Context, headers map[string]any) context.Context

func InjectToAmqp

func InjectToAmqp(ctx context.Context, payload amqp.Publishing) amqp.Publishing

func SetRouteTag

func SetRouteTag(ctx context.Context, route string)

Types

type Config

type Config struct {
	URL         string
	Rate        string
	TraceUint64 bool
}

func Flags

func Flags(fs *flag.FlagSet, prefix string, overrides ...flags.Override) *Config

type FinishSpan

type FinishSpan = func(err *error, options ...tr.SpanEndOption)

func StartSpan

func StartSpan(ctx context.Context, tracer tr.Tracer, name string, opts ...tr.SpanStartOption) (context.Context, FinishSpan)

type OtlpLogger

type OtlpLogger struct {
	slog.Handler
	Attributes []slog.Attr
	Uint64     bool
}

func (OtlpLogger) Handle

func (tl OtlpLogger) Handle(ctx context.Context, r slog.Record) error

type Service

type Service struct {
	TraceUint64 bool
	// contains filtered or unexported fields
}

func New

func New(ctx context.Context, config *Config) (Service, error)

func (Service) AddTraceToLogHandler

func (s Service) AddTraceToLogHandler(handler slog.Handler) slog.Handler

func (Service) Close

func (s Service) Close(ctx context.Context)

func (Service) MeterProvider

func (s Service) MeterProvider() meter.MeterProvider

func (Service) Middleware

func (s Service) Middleware(name string) func(next http.Handler) http.Handler

func (Service) TracerProvider

func (s Service) TracerProvider() tr.TracerProvider

type SimpleHeaderCarrier

type SimpleHeaderCarrier map[string]any

func (SimpleHeaderCarrier) Get

func (shc SimpleHeaderCarrier) Get(key string) string

func (SimpleHeaderCarrier) Keys

func (shc SimpleHeaderCarrier) Keys() []string

func (SimpleHeaderCarrier) Set

func (shc SimpleHeaderCarrier) Set(key string, value string)