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) GetServiceVersionAndEnv() (service, version, env string)
  • 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) GetServiceVersionAndEnv

func (s *Service) GetServiceVersionAndEnv() (service, version, env string)

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)