class ElasticAPM::Spies::MongoSpy::Subscriber

def push_event(event)
  return unless ElasticAPM.current_transaction
  ctx = Span::Context.new(
    instance: event.database_name,
    statement: nil,
    type: 'mongodb'.freeze,
    user: nil
  )
  span = ElasticAPM.span(event.command_name, TYPE, context: ctx)
  @events[event.operation_id] = span
end