Clase: Mongo::Server::Monitor Privado

Hereda:
Objeto
  • Objeto
Mostrar todo
Ampliado por:
Reenviable
Incluye:
BackgroundThread, Event::Publisher, Loggable
Definido en:
lib/mongo/server/monitor.rb,
lib/mongo/server/monitor/connection.rb,
lib/mongo/server/monitor/app_metadata.rb

Overview

Esta clase forma parte de una API privada. Evita usar esta clase si es posible, ya que puede ser eliminada o modificada en el futuro.

Responsable de sondear periódicamente un servidor a través de comandos hello para mantener el estado del servidor actualizado.

Realiza todo el trabajo en un hilo en segundo plano para no interferir con otras operaciones realizadas por el driver.

Desde:

  • 2.0.0

Definido bajo Namespace

Clases: AppMetadata, Conexión

Colapso delresumen constante

DEFAULT_HEARTBEAT_INTERVAL =

Esta constante forma parte de una API privada. Debe evitar usarla siempre que sea posible, ya que podría eliminarse o modificarse en el futuro.

El intervalo por defecto entre actualizaciones del estado del servidor es de 10 segundos.

Desde:

  • 2.0.0

10.freeze
MIN_SCAN_INTERVAL =

Esta constante forma parte de una API privada. Debe evitar usarla siempre que sea posible, ya que podría eliminarse o modificarse en el futuro.

El tiempo mínimo entre escaneos forzados del servidor. minHeartbeatFrequencyMS en la especificación SDAM.

Desde:

  • 2.0.0

0.5.freeze
RTT_WEIGHT_FACTOR =

Esta constante forma parte de una API privada. Debe evitar usarla siempre que sea posible, ya que podría eliminarse o modificarse en el futuro.

Obsoleto.

Se eliminará en la versión 3.0.

El factor de ponderación (alfa) para calcular el tiempo promedio de ida y vuelta en movimiento.

Desde:

  • 2.0.0

0.2.freeze

Constantes incluidas desde Loggable

Registrable::PREFIX

Resumen de atributos de la instancia colapsar

Atributos incluidos de Event::Publisher

#event_listeners

Resumen del método de instancia colapsar

Métodos incluidos desde BackgroundThread

#¡corre!, #¿corriendo?

Métodos incluidos desde Registrable

#log_debug, #log_error, #log_fatal, #log_info, #log_warn, #logger

Métodos incluidos desde Event::Publisher

#publicar

Detalles del constructor

#inicializar(servidor, listeners_de_eventos, supervisión, opciones = {}) ⇒ Monitor

Este método forma parte de una API privada. Debe evitarlo si es posible, ya que podría eliminarse o modificarse en el futuro.

Nota:

El monitor nunca debe ser instanciado directamente fuera de un servidor.

Cree el nuevo monitor de servidor.

Ejemplos:

Crear para supervisar el servidor.

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

Parámetros:

  • Server (Servidor) —

    El servidor a monitorizar.

  • event_listeners (Event::Listeners) —

    Los evento listeners.

  • Monitoring (supervisión) —

    La supervisión…

  • opciones (Hash) (por defecto: {}) —

    Las opciones.

Opciones Hash (options):

  • :tiempo de espera de conexión (Flotante) —

    El tiempo de espera, en segundos, que debe utilizarse al establecer la conexión de supervisión.

  • :intervalo_de_latidos (Flotante) —

    El intervalo entre comprobaciones regulares del servidor.

  • :logger (Logger) —

    Un registrador personalizado para usar.

  • :monitor_app_metadata (Mongo::servidor::supervisar::AppMetadata) —

    Los metadatos a utilizar para la conexión de monitoreo regular.

  • :push_monitor_app_metadata (Mongo::servidor::supervisar::AppMetadata) —

    Los metadatos que se utilizarán para la conexión del monitor de push.

  • :tiempo de espera del socket (Flotante) —

    El tiempo de espera, en segundos, para ejecutar operaciones en la conexión de supervisión.

Desde:

  • 2.0.0



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

def inicializar(Server, event_listeners, Monitoring, opciones = {})
  a menos que Monitoring.is_a?(Monitoring)
    propagar ArgumentError, "Tipo de supervisión incorrecto: #{supervisión.inspect}"
  end
  a menos que opciones[:app_metadata]
    propagar ArgumentError, 'Los metadatos de la aplicación son obligatorios'
  end
  a menos que opciones[:push_monitor_app_metadata]
    propagar ArgumentError, 'Serequieren metadatos de la aplicación Push Monitor'
  end
  @server = Server
  @event_listeners = event_listeners
  @monitoring = Monitoring
  @options = opciones.freeze
  @mutex = Mutex (exclusión mutua).Nuevo
  @sdam_mutex = Mutex (exclusión mutua).Nuevo
  @next_earliest_scan = @next_wanted_scan = Tiempo.ahora
  @update_mutex = Mutex (exclusión mutua).Nuevo
end

Detalles de los atributos de instancia

#conexión ⇒ Mongo::servidor::supervisar::Connection (solo lectura)

Este método forma parte de una API privada. Debe evitarlo si es posible, ya que podría eliminarse o modificarse en el futuro.

Devuelve la conexión La conexión a utilizar.

Devuelve:

Desde:

  • 2.0.0



103
104
105
 
# Archivo 'lib/mongo/server/monitor.rb', línea 103

def Conexión
  @conexión
end

#monitoring ⇒ Monitoring (readonly)

Este método forma parte de una API privada. Debe evitarlo si es posible, ya que podría eliminarse o modificarse en el futuro.

Supervisión de devoluciones La supervisión.

Devuelve:

Desde:

  • 2.0.0



125
126
127
 
# Archivo 'lib/mongo/server/monitor.rb', línea 125

def Monitoring
  @monitoring
end

#opciones ⇒ Hash (solo lectura)

Este método forma parte de una API privada. Debe evitarlo si es posible, ya que podría eliminarse o modificarse en el futuro.

Devuelve las opciones Opciones del servidor.

Devuelve:

  • (encriptada) —

    options Las opciones del servidor.

Desde:

  • 2.0.0



106
107
108
 
# Archivo 'lib/mongo/server/monitor.rb', línea 106

def opciones
  @options
end

#servidor ⇒ Servidor (sólo lectura)

Este método forma parte de una API privada. Debe evitarlo si es posible, ya que podría eliminarse o modificarse en el futuro.

Servidor de devoluciones El servidor que este supervisar está supervisando.

Devuelve:

  • (Servidor) —

    servidor El servidor que este monitor está supervisando.

Desde:

  • 2.0.0



100
101
102
 
# Archivo 'lib/mongo/server/monitor.rb', línea 100

def Server
  @server
end

Detalles del método de instancia

#create_push_monitor!(versión_de_topología) ⇒ Objeto

Este método forma parte de una API privada. Debe evitarlo si es posible, ya que podría eliminarse o modificarse en el futuro.

Desde:

  • 2.0.0



173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
 
# Archivo 'lib/mongo/server/monitor.rb', línea 173

def ¡crear_monitor_push!(topology_version)
  @update_mutex.sincronizar hacer
    si @push_monitor && !@push_monitor.¿correr?
      @push_monitor = nulo
    end

    @push_monitor ||= Monitor de empuje.Nuevo(
      sí mismo,
      topology_version,
      Monitoring,
      **Utils.shallow_symbolize_keys(opciones.fusionar(
        socket_timeout: intervalo_latido + Conexión.socket_timeout,
        app_metadata: opciones[:push_monitor_app_metadata],
        check_document: @conexión.check_document
      )),
    )
  end
end

#do_work ⇒ objeto

Este método forma parte de una API privada. Debe evitarlo si es posible, ya que podría eliminarse o modificarse en el futuro.

Realiza una verificación del servidor.

Desde:

  • 2.0.0



138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
 
# Archivo 'lib/mongo/server/monitor.rb', línea 138

def realizar_trabajo
  ¡escanear!
  # @next_wanted_scan puede ser actualizado por el monitor push.
  # Sin embargo, debemos verificar el indicador de terminación para que el monitor
  # El hilo se cierra cuando se solicita.
  bucle hacer
    delta = @next_wanted_scan - Tiempo.ahora
    si delta > 0
      señalado = Server.semáforo de escaneo.esperar(delta)
      si señalado || @solicitud_detencion
        break
      end
    else
      break
    end
  end
end

#heartbeat_interval ⇒ Float

Este método forma parte de una API privada. Debe evitarlo si es posible, ya que podría eliminarse o modificarse en el futuro.

El intervalo entre comprobaciones regulares del servidor.

Devuelve:

  • (Float) —

    El intervalo del latido, en segundos.

Desde:

  • 2.0.0



111
112
113
 
# Archivo 'lib/mongo/server/monitor.rb', línea 111

def intervalo_latido
  opciones[:intervalo_de_latidos] || DEFAULT_HEARTBEAT_INTERVAL
end

#push_monitor ⇒ Server::PushMonitor | nil

Este método forma parte de una API privada. Debe evitarlo si es posible, ya que podría eliminarse o modificarse en el futuro.

Devuelve el monitor push, si se está utilizando uno.

Devuelve:

Desde:

  • 2.0.0



129
130
131
132
133
 
# Archivo 'lib/mongo/server/monitor.rb', línea 129

def monitor_push
  @update_mutex.sincronizar hacer
    @push_monitor
  end
end

#¡reinicia! ⇒ Hilo

Este método forma parte de una API privada. Debe evitarlo si es posible, ya que podría eliminarse o modificarse en el futuro.

Reinicia el monitor del servidor a menos que el proceso actual esté todavía en ejecución.

Ejemplos:

Reinicia el monitor.

monitor.restart!

Devuelve:

  • (Thread) —

    El hilo en el que se ejecuta el monitor.

Desde:

  • 2.1.0



270
271
272
273
274
275
276
 
# Archivo 'lib/mongo/server/monitor.rb', línea 270

def ¡reiniciar!
  si @thread && @thread.alive?
    @thread
  else
    ejecutar!
  end
end

#run_sdam_flow(result, awaited: false, scan_error: nil) ⇒ objeto

Este método forma parte de una API privada. Debe evitarlo si es posible, ya que podría eliminarse o modificarse en el futuro.

Desde:

  • 2.0.0



236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
 
# Archivo 'lib/mongo/server/monitor.rb', línea 236

def run_sdam_flow(Resultado, esperado: false, error de escaneo: nulo)
  @sdam_mutex.sincronizar hacer
    old_description = Server.Descripción

    new_description = Descripción.Nuevo(
      Server.dirección,
      Resultado,
      tiempo promedio de ida y vuelta: Server.calculadora_de_tiempo_de_viaje_redondo.average_round_trip_time,
      minimum_round_trip_time: Server.calculadora_de_tiempo_de_viaje_redondo.tiempo mínimo de ida y vuelta
    )

    Server.clúster.run_sdam_flow(Server.Descripción, new_description, esperado: en espera, error de escaneo: scan_error)

    Server.Descripción.tocar hacer |new_description|
      a menos que en espera
        si new_description.¿desconocido? && !old_description.¿desconocido?
          @next_earliest_scan = @next_wanted_scan = Tiempo.ahora
        else
          @next_earliest_scan = Tiempo.ahora + MIN_SCAN_INTERVAL
          @next_wanted_scan = Tiempo.ahora + intervalo_latido
        end
      end
    end
  end
end

#scan! ⇒ Descripción

Este método forma parte de una API privada. Debe evitarlo si es posible, ya que podría eliminarse o modificarse en el futuro.

Nota:

Si el reloj del sistema se retrasa, este método puede permanecer inactivo durante mucho tiempo.

Nota:

El valor de retorno de este método está obsoleto. En la versión 3.0.0, este método no tendrá un valor de retorno.

Realice una verificación del servidor con limitación y actualice la descripción del servidor y el tiempo de ida y vuelta promedio.

Si se revisó el servidor hace menos de MIN_SCAN_INTERVAL segundos, se debe esperar hasta que hayan pasado MIN_SCAN_INTERVAL segundos desde la última revisión. A continuación, realiza la verificación que implica ejecutar hello en el servidor que se está supervisando y actualizar la descripción del servidor como resultado.

Devuelve:

Desde:

  • 2.0.0



219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
 
# Archivo 'lib/mongo/server/monitor.rb', línea 219

def ¡escanear!
  # Normalmente, el hilo en segundo plano invocaría este método.
  # Pero también es posible invocar scan! directamente sobre un monitor.
  # Permitir que solo se realice un escaneo a la vez.
  @mutex.sincronizar hacer
    throttle_scan_frequency!

    begin
      Resultado = do_scan
    rescate => e
      run_sdam_flow({}, error de escaneo: e)
    else
      run_sdam_flow(Resultado)
    end
  end
end

#¡stop! ⇒ true | false

Detener el hilo en segundo plano y esperar a que finalice durante un tiempo razonable.

Devuelve:

  • (true | false) —

    Si el hilo fue terminado.

Desde:

  • 2.0.0



162
163
164
165
166
167
168
169
170
171
 
# Archivo 'lib/mongo/server/monitor.rb', línea 162

def ¡detener!
  stop_push_monitor!

  # Reenviar el valor de retorno de super
  super.tocar hacer
    # Importante: la desconexión debería ocurrir después del hilo en segundo plano
    # termina.
    Conexión&.¡desconectar!
  end
end

#stop_push_monitor! ⇒ objeto

Este método forma parte de una API privada. Debe evitarlo si es posible, ya que podría eliminarse o modificarse en el futuro.

Desde:

  • 2.0.0



192
193
194
195
196
197
198
199
 
# Archivo 'lib/mongo/server/monitor.rb', línea 192

def stop_push_monitor!
  @update_mutex.sincronizar hacer
    si @push_monitor
      @push_monitor.¡detener!
      @push_monitor = nulo
    end
  end
end

#to_s ⇒ Object

Este método forma parte de una API privada. Debe evitarlo si es posible, ya que podría eliminarse o modificarse en el futuro.

Desde:

  • 2.0.0



278
279
280
 
# Archivo 'lib/mongo/server/monitor.rb', línea 278

def to_s
  "#<#{self.clase.name}:#{object_id} #{servidor.address}>"
end