http

Documentation

Index

• func InitHttpMetrics(meter metric.Meter)
• type HttpClientAttrsExtractor
  • func (h *HttpClientAttrsExtractor[REQUEST, RESPONSE, GETTER1, GETTER2]) GetSpanKey() attribute.Key
  • func (h *HttpClientAttrsExtractor[REQUEST, RESPONSE, GETTER1, GETTER2]) OnEnd(attributes []attribute.KeyValue, context context.Context, request REQUEST, ...) ([]attribute.KeyValue, context.Context)
  • func (h *HttpClientAttrsExtractor[REQUEST, RESPONSE, GETTER1, GETTER2]) OnStart(attributes []attribute.KeyValue, parentContext context.Context, ...) ([]attribute.KeyValue, context.Context)
• type HttpClientAttrsGetter
• type HttpClientMetric
  • func HttpClientMetrics() *HttpClientMetric
  • func (h HttpClientMetric) OnAfterEnd(context context.Context, endAttributes []attribute.KeyValue, endTime time.Time)
  • func (h HttpClientMetric) OnAfterStart(context context.Context, endTime time.Time)
  • func (h HttpClientMetric) OnBeforeEnd(ctx context.Context, startAttributes []attribute.KeyValue, startTime time.Time) context.Context
  • func (h HttpClientMetric) OnBeforeStart(parentContext context.Context, startTime time.Time) context.Context
• type HttpClientSpanNameExtractor
  • func (h *HttpClientSpanNameExtractor[REQUEST, RESPONSE]) Extract(request REQUEST) string
• type HttpClientSpanStatusExtractor
  • func (h HttpClientSpanStatusExtractor[REQUEST, RESPONSE]) Extract(span trace.Span, request REQUEST, response RESPONSE, err error)
• type HttpCommonAttrsExtractor
  • func (h *HttpCommonAttrsExtractor[REQUEST, RESPONSE, GETTER, GETTER2]) OnEnd(attributes []attribute.KeyValue, context context.Context, request REQUEST, ...) ([]attribute.KeyValue, context.Context)
  • func (h *HttpCommonAttrsExtractor[REQUEST, RESPONSE, GETTER1, GETTER2]) OnStart(attributes []attribute.KeyValue, parentContext context.Context, ...) ([]attribute.KeyValue, context.Context)
• type HttpCommonAttrsGetter
• type HttpServerAttrsExtractor
  • func (h *HttpServerAttrsExtractor[REQUEST, RESPONSE, GETTER1, GETTER2, GETTER3]) GetSpanKey() attribute.Key
  • func (h *HttpServerAttrsExtractor[REQUEST, RESPONSE, GETTER1, GETTER2, GETTER3]) OnEnd(attributes []attribute.KeyValue, context context.Context, request REQUEST, ...) ([]attribute.KeyValue, context.Context)
  • func (h *HttpServerAttrsExtractor[REQUEST, RESPONSE, GETTER1, GETTER2, GETTER3]) OnStart(attributes []attribute.KeyValue, parentContext context.Context, ...) ([]attribute.KeyValue, context.Context)
• type HttpServerAttrsGetter
• type HttpServerMetric
  • func HttpServerMetrics() *HttpServerMetric
  • func (h *HttpServerMetric) OnAfterEnd(context context.Context, endAttributes []attribute.KeyValue, endTime time.Time)
  • func (h *HttpServerMetric) OnAfterStart(context context.Context, endTime time.Time)
  • func (h *HttpServerMetric) OnBeforeEnd(ctx context.Context, startAttributes []attribute.KeyValue, startTime time.Time) context.Context
  • func (h *HttpServerMetric) OnBeforeStart(parentContext context.Context, startTime time.Time) context.Context
• type HttpServerSpanNameExtractor
  • func (h *HttpServerSpanNameExtractor[REQUEST, RESPONSE]) Extract(request REQUEST) string
• type HttpServerSpanStatusExtractor
  • func (h HttpServerSpanStatusExtractor[REQUEST, RESPONSE]) Extract(span trace.Span, request REQUEST, response RESPONSE, err error)

Functions

func InitHttpMetrics

func InitHttpMetrics(meter metric.Meter)

InitHttpMetrics TODO: The init function may be executed after the HttpServerOperationListener() method so we need to make sure the otel_setup is executed before all the init() function related to issue https://github.com/alibaba/opentelemetry-go-auto-instrumentation/issues/48

Types

type HttpClientAttrsExtractor

type HttpClientAttrsExtractor[REQUEST any, RESPONSE any, GETTER1 HttpClientAttrsGetter[REQUEST, RESPONSE], GETTER2 net.NetworkAttrsGetter[REQUEST, RESPONSE]] struct {
	Base             HttpCommonAttrsExtractor[REQUEST, RESPONSE, GETTER1, GETTER2]
	NetworkExtractor net.NetworkAttrsExtractor[REQUEST, RESPONSE, GETTER2]
}

func (*HttpClientAttrsExtractor[REQUEST, RESPONSE, GETTER1, GETTER2]) GetSpanKey

func (h *HttpClientAttrsExtractor[REQUEST, RESPONSE, GETTER1, GETTER2]) GetSpanKey() attribute.Key

func (*HttpClientAttrsExtractor[REQUEST, RESPONSE, GETTER1, GETTER2]) OnEnd

func (h *HttpClientAttrsExtractor[REQUEST, RESPONSE, GETTER1, GETTER2]) OnEnd(attributes []attribute.KeyValue, context context.Context, request REQUEST, response RESPONSE, err error) ([]attribute.KeyValue, context.Context)

func (*HttpClientAttrsExtractor[REQUEST, RESPONSE, GETTER1, GETTER2]) OnStart

func (h *HttpClientAttrsExtractor[REQUEST, RESPONSE, GETTER1, GETTER2]) OnStart(attributes []attribute.KeyValue, parentContext context.Context, request REQUEST) ([]attribute.KeyValue, context.Context)

type HttpClientAttrsGetter

type HttpClientAttrsGetter[REQUEST any, RESPONSE any] interface {
	HttpCommonAttrsGetter[REQUEST, RESPONSE]
	net.NetworkAttrsGetter[REQUEST, RESPONSE]
	GetUrlFull(request REQUEST) string
	GetServerAddress(request REQUEST) string
	GetServerPort(request REQUEST) int
}

type HttpClientMetric

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

func HttpClientMetrics

func HttpClientMetrics() *HttpClientMetric

func (HttpClientMetric) OnAfterEnd

func (h HttpClientMetric) OnAfterEnd(context context.Context, endAttributes []attribute.KeyValue, endTime time.Time)

func (HttpClientMetric) OnAfterStart

func (h HttpClientMetric) OnAfterStart(context context.Context, endTime time.Time)

func (HttpClientMetric) OnBeforeEnd

func (h HttpClientMetric) OnBeforeEnd(ctx context.Context, startAttributes []attribute.KeyValue, startTime time.Time) context.Context

func (HttpClientMetric) OnBeforeStart

func (h HttpClientMetric) OnBeforeStart(parentContext context.Context, startTime time.Time) context.Context

type HttpClientSpanNameExtractor

type HttpClientSpanNameExtractor[REQUEST any, RESPONSE any] struct {
	Getter HttpClientAttrsGetter[REQUEST, RESPONSE]
}

func (*HttpClientSpanNameExtractor[REQUEST, RESPONSE]) Extract

func (h *HttpClientSpanNameExtractor[REQUEST, RESPONSE]) Extract(request REQUEST) string

type HttpClientSpanStatusExtractor

type HttpClientSpanStatusExtractor[REQUEST any, RESPONSE any] struct {
	Getter HttpCommonAttrsGetter[REQUEST, RESPONSE]
}

func (HttpClientSpanStatusExtractor[REQUEST, RESPONSE]) Extract

func (h HttpClientSpanStatusExtractor[REQUEST, RESPONSE]) Extract(span trace.Span, request REQUEST, response RESPONSE, err error)

type HttpCommonAttrsExtractor

type HttpCommonAttrsExtractor[REQUEST any, RESPONSE any, GETTER1 HttpCommonAttrsGetter[REQUEST, RESPONSE], GETTER2 net.NetworkAttrsGetter[REQUEST, RESPONSE]] struct {
	HttpGetter       GETTER1
	NetGetter        GETTER2
	AttributesFilter func(attrs []attribute.KeyValue) []attribute.KeyValue
}

func (*HttpCommonAttrsExtractor[REQUEST, RESPONSE, GETTER, GETTER2]) OnEnd

func (h *HttpCommonAttrsExtractor[REQUEST, RESPONSE, GETTER, GETTER2]) OnEnd(attributes []attribute.KeyValue, context context.Context, request REQUEST, response RESPONSE, err error) ([]attribute.KeyValue, context.Context)

func (*HttpCommonAttrsExtractor[REQUEST, RESPONSE, GETTER1, GETTER2]) OnStart

func (h *HttpCommonAttrsExtractor[REQUEST, RESPONSE, GETTER1, GETTER2]) OnStart(attributes []attribute.KeyValue, parentContext context.Context, request REQUEST) ([]attribute.KeyValue, context.Context)

type HttpCommonAttrsGetter

type HttpCommonAttrsGetter[REQUEST any, RESPONSE any] interface {
	GetRequestMethod(request REQUEST) string
	GetHttpRequestHeader(request REQUEST, name string) []string
	GetHttpResponseStatusCode(request REQUEST, response RESPONSE, err error) int
	GetHttpResponseHeader(request REQUEST, response RESPONSE, name string) []string
	GetErrorType(request REQUEST, response RESPONSE, err error) string
}

type HttpServerAttrsExtractor

type HttpServerAttrsExtractor[REQUEST any, RESPONSE any, GETTER1 HttpServerAttrsGetter[REQUEST, RESPONSE], GETTER2 net.NetworkAttrsGetter[REQUEST, RESPONSE], GETTER3 net.UrlAttrsGetter[REQUEST]] struct {
	Base             HttpCommonAttrsExtractor[REQUEST, RESPONSE, GETTER1, GETTER2]
	NetworkExtractor net.NetworkAttrsExtractor[REQUEST, RESPONSE, GETTER2]
	UrlExtractor     net.UrlAttrsExtractor[REQUEST, RESPONSE, GETTER3]
}

func (*HttpServerAttrsExtractor[REQUEST, RESPONSE, GETTER1, GETTER2, GETTER3]) GetSpanKey

func (h *HttpServerAttrsExtractor[REQUEST, RESPONSE, GETTER1, GETTER2, GETTER3]) GetSpanKey() attribute.Key

func (*HttpServerAttrsExtractor[REQUEST, RESPONSE, GETTER1, GETTER2, GETTER3]) OnEnd

func (h *HttpServerAttrsExtractor[REQUEST, RESPONSE, GETTER1, GETTER2, GETTER3]) OnEnd(attributes []attribute.KeyValue, context context.Context, request REQUEST, response RESPONSE, err error) ([]attribute.KeyValue, context.Context)

func (*HttpServerAttrsExtractor[REQUEST, RESPONSE, GETTER1, GETTER2, GETTER3]) OnStart

func (h *HttpServerAttrsExtractor[REQUEST, RESPONSE, GETTER1, GETTER2, GETTER3]) OnStart(attributes []attribute.KeyValue, parentContext context.Context, request REQUEST) ([]attribute.KeyValue, context.Context)

type HttpServerAttrsGetter

type HttpServerAttrsGetter[REQUEST any, RESPONSE any] interface {
	HttpCommonAttrsGetter[REQUEST, RESPONSE]
	net.UrlAttrsGetter[REQUEST]
	net.NetworkAttrsGetter[REQUEST, RESPONSE]
	GetUrlScheme(request REQUEST) string
	GetUrlPath(request REQUEST) string
	GetUrlQuery(request REQUEST) string
	GetHttpRoute(request REQUEST) string
}

type HttpServerMetric

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

func HttpServerMetrics

func HttpServerMetrics() *HttpServerMetric

func (*HttpServerMetric) OnAfterEnd

func (h *HttpServerMetric) OnAfterEnd(context context.Context, endAttributes []attribute.KeyValue, endTime time.Time)

func (*HttpServerMetric) OnAfterStart

func (h *HttpServerMetric) OnAfterStart(context context.Context, endTime time.Time)

func (*HttpServerMetric) OnBeforeEnd

func (h *HttpServerMetric) OnBeforeEnd(ctx context.Context, startAttributes []attribute.KeyValue, startTime time.Time) context.Context

func (*HttpServerMetric) OnBeforeStart

func (h *HttpServerMetric) OnBeforeStart(parentContext context.Context, startTime time.Time) context.Context

type HttpServerSpanNameExtractor

type HttpServerSpanNameExtractor[REQUEST any, RESPONSE any] struct {
	Getter HttpServerAttrsGetter[REQUEST, RESPONSE]
}

func (*HttpServerSpanNameExtractor[REQUEST, RESPONSE]) Extract

func (h *HttpServerSpanNameExtractor[REQUEST, RESPONSE]) Extract(request REQUEST) string

type HttpServerSpanStatusExtractor

type HttpServerSpanStatusExtractor[REQUEST any, RESPONSE any] struct {
	Getter HttpCommonAttrsGetter[REQUEST, RESPONSE]
}

func (HttpServerSpanStatusExtractor[REQUEST, RESPONSE]) Extract

func (h HttpServerSpanStatusExtractor[REQUEST, RESPONSE]) Extract(span trace.Span, request REQUEST, response RESPONSE, err error)