Class: Mongo::Monitoring

# File 'lib/mongo/monitoring.rb', line 242

attr_reader :options

# File 'lib/mongo/monitoring.rb', line 359

def initialize_copy(original)
  @subscribers = {}
  original.subscribers.each do |k, v|
    @subscribers[k] = v.dup
  end
end

# File 'lib/mongo/monitoring.rb', line 311

def publish_heartbeat(server, awaited: false)
  if monitoring?
    started_event = Event::ServerHeartbeatStarted.new(
      server.address, awaited: awaited)
    started(SERVER_HEARTBEAT, started_event)
  end

  # The duration we publish in heartbeat succeeded/failed events is
  # the time spent on the entire heartbeat. This could include time
  # to connect the socket (including TLS handshake), not just time
  # spent on hello call itself.
  # The spec at https://github.com/mongodb/specifications/blob/master/source/server-discovery-and-monitoring/server-discovery-and-monitoring-monitoring.rst
  # requires that the duration exposed here start from "sending the
  # message" (hello). This requirement does not make sense if,
  # for example, we were never able to connect to the server at all
  # and thus hello was never sent.
  start_time = Utils.monotonic_time

  begin
    result = yield
  rescue => exc
    if monitoring?
      event = Event::ServerHeartbeatFailed.new(
        server.address,
        Utils.monotonic_time - start_time,
        exc,
        awaited: awaited,
        started_event: started_event,
      )
      failed(SERVER_HEARTBEAT, event)
    end
    raise
  else
    if monitoring?
      event = Event::ServerHeartbeatSucceeded.new(
        server.address,
        Utils.monotonic_time - start_time,
        awaited: awaited,
        started_event: started_event,
      )
      succeeded(SERVER_HEARTBEAT, event)
    end
    result
  end
end

# File 'lib/mongo/monitoring.rb', line 258

def published(topic, event)
  subscribers_for(topic).each{ |subscriber| subscriber.published(event) }
end

# File 'lib/mongo/monitoring.rb', line 274

def started(topic, event)
  subscribers_for(topic).each{ |subscriber| subscriber.started(event) }
end

# File 'lib/mongo/monitoring.rb', line 290

def succeeded(topic, event)
  subscribers_for(topic).each{ |subscriber| subscriber.succeeded(event) }
end