telemetry

Documentation

Index

• func AddOpenTelemetryToClient(httpClient *http.Client, meterProvider meter.MeterProvider, ...) *http.Client
• func AddTraceToLogger(span tr.Span, logger *slog.Logger) *slog.Logger
• 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 Service
  • func New(ctx context.Context, config *Config) (Service, error)
  • 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

Functions

func AddOpenTelemetryToClient

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

func AddTraceToLogger

func AddTraceToLogger(span tr.Span, logger *slog.Logger) *slog.Logger

Types

type Config

type Config struct {
	URL  string
	Rate string
}

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 Service

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

func New

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

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