observ

Documentation

Index

• func Middleware(log *zap.Logger, meter metric.Meter) func(next http.Handler) http.Handler
• func ReadUserIP(r *http.Request) string
• type LicenseResolver
  • func (l *LicenseResolver) ResolveLicense(ctx context.Context, m validation.Module) (validation.License, error)
• type ReadCounter
  • func (r *ReadCounter) Read(b []byte) (int, error)
• type TraceTransport
  • func (t *TraceTransport) RoundTrip(request *http.Request) (*http.Response, error)
• type WriterInterceptor
  • func (w *WriterInterceptor) Code() int
  • func (w *WriterInterceptor) Write(b []byte) (int, error)
  • func (w *WriterInterceptor) WriteHeader(code int)

Functions

func Middleware

func Middleware(log *zap.Logger, meter metric.Meter) func(next http.Handler) http.Handler

func ReadUserIP

func ReadUserIP(r *http.Request) string

Types

type LicenseResolver

type LicenseResolver struct {
	validation.LicenseResolver
	Meter metric.Meter
	// contains filtered or unexported fields
}

func (*LicenseResolver) ResolveLicense

func (l *LicenseResolver) ResolveLicense(ctx context.Context, m validation.Module) (validation.License, error)

type ReadCounter

type ReadCounter struct {
	io.ReadCloser

	Size int
}

func (*ReadCounter) Read

func (r *ReadCounter) Read(b []byte) (int, error)

type TraceTransport

type TraceTransport struct {
	http.RoundTripper

	ServiceName string
	Tracer      trace.Tracer
	Meter       metric.Meter
	// contains filtered or unexported fields
}

TraceTransport is a wrapper of http.RoundTripper for tracing requests through opentelemetry

func (*TraceTransport) RoundTrip

func (t *TraceTransport) RoundTrip(request *http.Request) (*http.Response, error)

type WriterInterceptor

type WriterInterceptor struct {
	http.ResponseWriter

	Size int
	// contains filtered or unexported fields
}

func (*WriterInterceptor) Code

func (w *WriterInterceptor) Code() int

func (*WriterInterceptor) Write

func (w *WriterInterceptor) Write(b []byte) (int, error)

func (*WriterInterceptor) WriteHeader

func (w *WriterInterceptor) WriteHeader(code int)