in input/elasticapm/internal/modeldecoder/v2/decoder.go [1298:1523]
func mapToTransactionModel(from *transaction, event *modelpb.APMEvent) {
out := modelpb.Transaction{}
event.Transaction = &out
// overwrite metadata with event specific information
mapToServiceModel(from.Context.Service, &event.Service)
mapToAgentModel(from.Context.Service.Agent, &event.Agent)
overwriteUserInMetadataModel(from.Context.User, event)
mapToUserAgentModel(from.Context.Request.Headers, &event.UserAgent)
mapToClientModel(from.Context.Request, &event.Source, &event.Client)
if from.FAAS.IsSet() {
if event.Faas == nil {
event.Faas = &modelpb.Faas{}
}
mapToFAASModel(from.FAAS, event.Faas)
}
if from.Context.Cloud.IsSet() {
if event.Cloud == nil {
event.Cloud = &modelpb.Cloud{}
}
mapToCloudModel(from.Context.Cloud, event.Cloud)
}
mapToDroppedSpansModel(from.DroppedSpanStats, event.Transaction)
// map transaction specific data
if from.Context.IsSet() {
if len(from.Context.Custom) > 0 {
out.Custom = modeldecoderutil.ToKv(from.Context.Custom, out.Custom)
}
if len(from.Context.Tags) > 0 {
modeldecoderutil.MergeLabels(from.Context.Tags, event)
}
if from.Context.Message.IsSet() {
out.Message = &modelpb.Message{}
if from.Context.Message.Age.IsSet() {
val := uint64(from.Context.Message.Age.Milliseconds.Val)
out.Message.AgeMillis = &val
}
if from.Context.Message.Body.IsSet() {
out.Message.Body = from.Context.Message.Body.Val
}
if from.Context.Message.Headers.IsSet() {
out.Message.Headers = modeldecoderutil.HTTPHeadersToModelpb(from.Context.Message.Headers.Val, out.Message.Headers)
}
if from.Context.Message.Queue.IsSet() && from.Context.Message.Queue.Name.IsSet() {
out.Message.QueueName = from.Context.Message.Queue.Name.Val
}
if from.Context.Message.RoutingKey.IsSet() {
out.Message.RoutingKey = from.Context.Message.RoutingKey.Val
}
}
if from.Context.Request.IsSet() {
if event.Http == nil {
event.Http = &modelpb.HTTP{}
}
event.Http.Request = &modelpb.HTTPRequest{}
mapToRequestModel(from.Context.Request, event.Http.Request)
if from.Context.Request.HTTPVersion.IsSet() {
event.Http.Version = from.Context.Request.HTTPVersion.Val
}
}
if from.Context.Request.URL.IsSet() {
if event.Url == nil {
event.Url = &modelpb.URL{}
}
mapToRequestURLModel(from.Context.Request.URL, event.Url)
}
if from.Context.Response.IsSet() {
if event.Http == nil {
event.Http = &modelpb.HTTP{}
}
event.Http.Response = &modelpb.HTTPResponse{}
mapToResponseModel(from.Context.Response, event.Http.Response)
}
if from.Context.Page.IsSet() {
if from.Context.Page.URL.IsSet() && !from.Context.Request.URL.IsSet() {
event.Url = modelpb.ParseURL(from.Context.Page.URL.Val, "", "")
}
if from.Context.Page.Referer.IsSet() {
if event.Http == nil {
event.Http = &modelpb.HTTP{}
}
if event.Http.Request == nil {
event.Http.Request = &modelpb.HTTPRequest{}
}
if event.Http.Request.Referrer == "" {
event.Http.Request.Referrer = from.Context.Page.Referer.Val
}
}
}
}
if from.Duration.IsSet() {
if event.Event == nil {
event.Event = &modelpb.Event{}
}
event.Event.Duration = uint64(from.Duration.Val * float64(time.Millisecond))
}
if from.ID.IsSet() {
out.Id = from.ID.Val
event.Span = &modelpb.Span{}
event.Span.Id = from.ID.Val
}
if from.Marks.IsSet() {
out.Marks = make(map[string]*modelpb.TransactionMark, len(from.Marks.Events))
for event, val := range from.Marks.Events {
if len(val.Measurements) > 0 {
tm := modelpb.TransactionMark{}
tm.Measurements = val.Measurements
out.Marks[event] = &tm
}
}
}
if from.Name.IsSet() {
out.Name = from.Name.Val
}
if event.Event == nil {
event.Event = &modelpb.Event{}
}
if from.Outcome.IsSet() {
event.Event.Outcome = from.Outcome.Val
} else {
if from.Context.Response.StatusCode.IsSet() {
statusCode := from.Context.Response.StatusCode.Val
if statusCode >= http.StatusInternalServerError {
event.Event.Outcome = "failure"
} else {
event.Event.Outcome = "success"
}
} else {
event.Event.Outcome = "unknown"
}
}
if from.ParentID.IsSet() {
event.ParentId = from.ParentID.Val
}
if from.Result.IsSet() {
out.Result = from.Result.Val
}
sampled := true
if from.Sampled.IsSet() {
sampled = from.Sampled.Val
}
out.Sampled = sampled
if from.SampleRate.IsSet() {
if from.SampleRate.Val > 0 {
out.RepresentativeCount = 1 / from.SampleRate.Val
}
} else {
out.RepresentativeCount = 1
}
if from.Session.ID.IsSet() {
event.Session = &modelpb.Session{}
event.Session.Id = from.Session.ID.Val
event.Session.Sequence = uint64(from.Session.Sequence.Val)
}
if from.SpanCount.Dropped.IsSet() {
if out.SpanCount == nil {
out.SpanCount = &modelpb.SpanCount{}
}
dropped := uint32(from.SpanCount.Dropped.Val)
out.SpanCount.Dropped = &dropped
}
if from.SpanCount.Started.IsSet() {
if out.SpanCount == nil {
out.SpanCount = &modelpb.SpanCount{}
}
started := uint32(from.SpanCount.Started.Val)
out.SpanCount.Started = &started
}
if !from.Timestamp.Val.IsZero() {
event.Timestamp = modelpb.FromTime(from.Timestamp.Val)
}
if from.TraceID.IsSet() {
event.Trace = &modelpb.Trace{}
event.Trace.Id = from.TraceID.Val
}
if from.Type.IsSet() {
out.Type = from.Type.Val
}
if from.UserExperience.IsSet() {
out.UserExperience = &modelpb.UserExperience{}
out.UserExperience.CumulativeLayoutShift = -1
out.UserExperience.FirstInputDelay = -1
out.UserExperience.TotalBlockingTime = -1
out.UserExperience.LongTask = nil
if from.UserExperience.CumulativeLayoutShift.IsSet() {
out.UserExperience.CumulativeLayoutShift = from.UserExperience.CumulativeLayoutShift.Val
}
if from.UserExperience.FirstInputDelay.IsSet() {
out.UserExperience.FirstInputDelay = from.UserExperience.FirstInputDelay.Val
}
if from.UserExperience.TotalBlockingTime.IsSet() {
out.UserExperience.TotalBlockingTime = from.UserExperience.TotalBlockingTime.Val
}
if from.UserExperience.Longtask.IsSet() {
out.UserExperience.LongTask = &modelpb.LongtaskMetrics{}
out.UserExperience.LongTask.Count = uint64(from.UserExperience.Longtask.Count.Val)
out.UserExperience.LongTask.Sum = from.UserExperience.Longtask.Sum.Val
out.UserExperience.LongTask.Max = from.UserExperience.Longtask.Max.Val
}
}
if from.OTel.IsSet() {
if event.Span == nil {
event.Span = &modelpb.Span{}
}
mapOTelAttributesTransaction(from.OTel, event)
}
if len(from.Links) > 0 {
if event.Span == nil {
event.Span = &modelpb.Span{}
}
event.Span.Links = modeldecoderutil.ResliceAndPopulateNil(
event.Span.Links,
len(from.Links),
modeldecoderutil.NewType[modelpb.SpanLink],
)
mapSpanLinks(from.Links, event.Span.Links)
}
if out.Type == "" {
out.Type = "unknown"
}
}