Method: Mongo::Server::Monitor#initialize

Defined in:
lib/mongo/server/monitor.rb

#initialize(server, event_listeners, monitoring, options = {}) ⇒ Monitor

This method is part of a private API. You should avoid using this method if possible, as it may be removed or be changed in the future.

Note:

Monitor must never be directly instantiated outside of a Server.

Create the new server monitor.

Examples:

Create the server monitor.

Mongo::Server::Monitor.new(address, listeners, monitoring)

Parameters:

  • server (Server) —

    The server to monitor.

  • event_listeners (Event::Listeners) —

    The event listeners.

  • monitoring (Monitoring) —

    The monitoring..

  • options (Hash) (defaults to: {}) —

    The options.

Options Hash (options):

  • :connect_timeout (Float) —

    The timeout, in seconds, to use when establishing the monitoring connection.

  • :heartbeat_interval (Float) —

    The interval between regular server checks.

  • :logger (Logger) —

    A custom logger to use.

  • :monitor_app_metadata (Mongo::Server::Monitor::AppMetadata) —

    The metadata to use for regular monitoring connection.

  • :push_monitor_app_metadata (Mongo::Server::Monitor::AppMetadata) —

    The metadata to use for push monitor’s connection.

  • :socket_timeout (Float) —

    The timeout, in seconds, to execute operations on the monitoring connection.

Since:

  • 2.0.0



78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
 
# File 'lib/mongo/server/monitor.rb', line 78

def initialize(server, event_listeners, monitoring, options = {})
  unless monitoring.is_a?(Monitoring)
    raise ArgumentError, "Wrong monitoring type: #{monitoring.inspect}"
  end
  unless options[:app_metadata]
    raise ArgumentError, 'App metadata is required'
  end
  unless options[:push_monitor_app_metadata]
    raise ArgumentError, 'Push monitor app metadata is required'
  end
  @server = server
  @event_listeners = event_listeners
  @monitoring = monitoring
  @options = options.freeze
  @mutex = Mutex.new
  @sdam_mutex = Mutex.new
  @next_earliest_scan = @next_wanted_scan = Time.now
  @update_mutex = Mutex.new
end