in lib/elastic_apm/spies/mongo.rb [65:95]
def push_event(event)
return unless ElasticAPM.current_transaction
collection =
if event.command[event.command_name] == 1 ||
event.command[event.command_name].is_a?(BSON::Int64)
event.command[:collection]
else
event.command[event.command_name]
end
name = [event.database_name,
collection,
event.command_name].compact.join('.')
span =
ElasticAPM.start_span(
name,
TYPE,
subtype: SUBTYPE,
action: ACTION,
context: build_context(event)
)
events << span
end