Sha256: 1de21d9f91811964e00151acd399994d287f5322ff64c8348cfd5638e5aa0b5e
Contents?: true
Size: 1.81 KB
Versions: 9
Compression:
Stored size: 1.81 KB
Contents
# frozen_string_literal: true
module ElasticAPM
module Transport
module Serializers
# @api private
class SpanSerializer < Serializer
def initialize(config)
super
@context_serializer = ContextSerializer.new(config)
end
attr_reader :context_serializer
# rubocop:disable Metrics/MethodLength, Metrics/AbcSize
def build(span)
{
span: {
id: span.id,
transaction_id: span.transaction_id,
parent_id: span.parent_id,
name: keyword_field(span.name),
type: keyword_field(span.type),
duration: ms(span.duration),
context: context_serializer.build(span.context),
stacktrace: span.stacktrace.to_a,
timestamp: span.timestamp,
trace_id: span.trace_id
}
}
end
# rubocop:enable Metrics/MethodLength, Metrics/AbcSize
# @api private
class ContextSerializer < Serializer
def build(context)
return unless context
{ sync: context.sync }.tap do |base|
base[:db] = build_db(context.db) if context.db
base[:http] = build_http(context.http) if context.http
end
end
private
def build_db(db)
return unless db
{
instance: db.instance,
statement: db.statement,
type: db.type,
user: db.user
}
end
def build_http(http)
return unless http
{
url: http.url,
status_code: http.status_code.to_i,
method: keyword_field(http.method)
}
end
end
end
end
end
end
Version data entries
9 entries across 9 versions & 1 rubygems