in elastictransport/instrumentation.go [186:200]
func (i ElasticsearchOpenTelemetry) AfterRequest(req *http.Request, system, endpoint string) {
span := trace.SpanFromContext(req.Context())
if span.IsRecording() {
span.SetAttributes(
attribute.String(attrDbSystem, system),
attribute.String(attrDbOperation, endpoint),
attribute.String(attrHttpRequestMethod, req.Method),
attribute.String(attrUrlFull, req.URL.String()),
attribute.String(attrServerAddress, req.URL.Hostname()),
)
if value, err := strconv.ParseInt(req.URL.Port(), 10, 32); err == nil {
span.SetAttributes(attribute.Int64(attrServerPort, value))
}
}
}