Classe: Mongo::Servidor::Monitor Privado

Herda:
Objeto
  • Objeto
mostrar tudo
Estendido por:
Encaminhável
Inclui:
BackgroundThread, Evento::editor, Loggable
Definido em:
lib/mongo/ servidor/monitor.rb,
lib/mongo/ servidor/monitor/connection.rb,
lib/mongo/ servidor/monitor/app_metadata.rb

Visão geral

Esta classe faz parte de uma API privada. Evite usar essa classe, se possível, pois ela pode ser removida ou alterada no futuro.

Responsáveis por pesquisar periodicamente um servidor por meio de comandos hello para manter o status do servidor atualizado.

Tudo funciona em um thread em background para não interferir em outras operações realizadas pelo driver.

Desde:

  • 2.0.0

Definido sob namespace

Classes: AppMetadata, Conexão

Colapsode resumo constante

DEFAULT_HEARTBEAD_INTERVAL =

Essa constante faz parte de uma API privada. Você deve evitar usar essa constante, se possível, pois ela pode ser removida ou alterada no futuro.

O intervalo padrão entre as atualizações de status do servidor é de 10 segundos.

Desde:

  • 2.0.0

10
MIN_SCAN_INTERVAL =

Essa constante faz parte de uma API privada. Você deve evitar usar essa constante, se possível, pois ela pode ser removida ou alterada no futuro.

O tempo mínimo entre as verificações forçadas do servidor . É minHeartbeatFrequencyMS na especificação SDAM.

Desde:

  • 2.0.0

0.5
RTT_WEight_FACTOR =

Essa constante faz parte de uma API privada. Você deve evitar usar essa constante, se possível, pois ela pode ser removida ou alterada no futuro.

Obsoleto.

Será removido na versão 3.0.

O fator de ponderação (alfa) para calcular o tempo médio de ida e volta em movimento.

Desde:

  • 2.0.0

0.2

Constantes incluídas do Loggable

Loggable::Prefix

Recolhimento do Resumo do atributo de instância

Atributos incluídos do Evento::editor

#event_listeners

Recolhimento do Resumo do método de instância

Métodos incluídos do BackgroundThread

#run!, #correndo?

Métodos incluídos no Loggable

#log_debug, #log_error, #log_fatal, #log_info, #log_WARN, #logger

Métodos incluídos do Event::publisher

#publish

Detalhes do construtor

#initialize(servidor, event_listeners, monitoramento, opções = {}) ➤ Monitorar

Este método faz parte de uma API privada. Evite usar esse método, se possível, pois ele pode ser removido ou alterado no futuro.

Observação:

O Monitor nunca deve ser diretamente instanciado fora de um Servidor.

Crie o novo monitor de servidor .

Exemplos:

Crie o monitor do servidor .

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

Parâmetros:

Hash de opções (opções):

  • :connect_timeout (Flutuante) —

    O tempo limite, em segundos, a ser usado ao estabelecer a conexão de monitoramento.

  • : heartbeat_interval (Flutuante) —

    O intervalo entre verificações regulares do servidor .

  • :logger (Registrador) —

    Um registrador personalizado para usar.

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

    Os metadados a serem usados para conexão de monitoramento regular.

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

    Os metadados a serem usados na conexão do monitor de push.

  • :socket_timeout (Flutuante) —

    O timeout, em segundos, para executar operações na conexão de monitoramento.

Aumenta:

  • (ArgumentError)

Desde:

  • 2.0.0



76
77
78
79
80
81
82
83
84
85
86
87
88
89
 
# Arquivo 'lib/mongo/ servidor/monitor.rb', linha 76

def inicializar(Servidor, event_listeners, Monitoramento, opções = {})
  aumentar ArgumentError, "Tipo de monitoramento incorreto: #{monitoring.inspect}" a menos que Monitoramento.is_a?(Monitoramento)
  aumentar ArgumentError, ' Osmetadados do aplicativo são obrigatórios' a menos que opções[:app_metadata]
  aumentar ArgumentError, ' Osmetadados do aplicativo de monitoramento são necessários' a menos que opções[:push_monitor_app_metadata]

  @server = Servidor
  @event_listeners = event_listeners
  @monitoring = Monitoramento
  @opções = opções.congelar
  @mutex = Mutex.Novo
  @sdam_mutex = Mutex.Novo
  @next_earlyest_scan = @next_Quered_scan = Hora.agora
  @update_mutex = Mutex.Novo
end

Detalhes do atributo da instância

#connection ➤ Mongo::Server::Monitor::Connection (somente leitura)

Este método faz parte de uma API privada. Evite usar esse método, se possível, pois ele pode ser removido ou alterado no futuro.

Retorna a conexão A conexão a ser usada.

Retorna:

Desde:

  • 2.0.0



96
97
98
 
# Arquivo 'lib/mongo/ servidor/monitor.rb', linha 96

def Conexão
  @connection
end

#Monitoring ➤ Monitoramento (somente leitura)

Este método faz parte de uma API privada. Evite usar esse método, se possível, pois ele pode ser removido ou alterado no futuro.

Monitoramento de retornos O monitoramento.

Retorna:

Desde:

  • 2.0.0



118
119
120
 
# Arquivo 'lib/mongo/ servidor/monitor.rb', linha 118

def Monitoramento
  @monitoring
end

#opções ➤ Hash (somente leitura)

Este método faz parte de uma API privada. Evite usar esse método, se possível, pois ele pode ser removido ou alterado no futuro.

Retorna opções As opções do servidor .

Retorna:

  • (Hash) —

    options As opções do servidor .

Desde:

  • 2.0.0



99
100
101
 
# Arquivo 'lib/mongo/ servidor/monitor.rb', linha 99

def opções
  @opções
end

#servidor ➤ Servidor (somente leitura)

Este método faz parte de uma API privada. Evite usar esse método, se possível, pois ele pode ser removido ou alterado no futuro.

Retorna servidor O servidor que este monitor está monitorando.

Retorna:

  • (Servidor MongoDB) —

    servidor O servidor que este monitor está monitorando.

Desde:

  • 2.0.0



93
94
95
 
# Arquivo 'lib/mongo/ servidor/monitor.rb', linha 93

def Servidor
  @server
end

Detalhes do método de instância

#create_push_monitor!(topology_version) ➤ Objeto

Este método faz parte de uma API privada. Evite usar esse método, se possível, pois ele pode ser removido ou alterado no futuro.

Desde:

  • 2.0.0



162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
 
# Arquivo 'lib/mongo/ servidor/monitor.rb', linha 162

def create_push_monitor!(topology_version)
  @update_mutex.sincronizar fazer
    @push_monitor = nada se @push_monitor && !@push_monitor.executando?

    @push_monitor ||= PushMonitor.Novo(
      auto,
      topology_version,
      Monitoramento,
      **Utilidades.raso_symbolize_keys(opções.mesclar(
                                       socket_timeout: heartbeat_interval + Conexão.socket_timeout,
                                       app_metadata: opções[:push_monitor_app_metadata],
                                       check_document: @connection.check_document
                                     ))
    )
  end
end

#do_work ➤ Objeto

Este método faz parte de uma API privada. Evite usar esse método, se possível, pois ele pode ser removido ou alterado no futuro.

Execute uma verificação do servidor.

Desde:

  • 2.0.0



131
132
133
134
135
136
137
138
139
140
141
142
143
 
# Arquivo 'lib/mongo/ servidor/monitor.rb', linha 131

def do_work
  digitalizar!
  # @next_Quered_scan pode ser atualizado pelo monitor de push.
  # No entanto, precisamos verificar se há sinalizador de encerramento para que o monitor
  # thread é encerrado quando solicitado.
  loop fazer
    delta, delta = @next_Quered_scan - Hora.agora
    intervalo a menos que delta, delta > 0

    sinalizado = Servidor.varredura_semafore.esperar(delta, delta)
    intervalo se sinalizado || @stop_requested
  end
end

#heartbeat_interval ➤ Flutuante

Este método faz parte de uma API privada. Evite usar esse método, se possível, pois ele pode ser removido ou alterado no futuro.

O intervalo entre verificações regulares do servidor .

Retorna:

  • (Flutuante) —

    O intervalo de pulsação, em segundos.

Desde:

  • 2.0.0



104
105
106
 
# Arquivo 'lib/mongo/ servidor/monitor.rb', linha 104

def heartbeat_interval
  opções[: heartbeat_interval] || DEFAULT_HEARTBEAD_INTERVAL
end

#push_monitor ➤ Servidor::PushMonitor | nada

Este método faz parte de uma API privada. Evite usar esse método, se possível, pois ele pode ser removido ou alterado no futuro.

Retorna o monitor de push, se houver um sendo usado.

Retorna:

Desde:

  • 2.0.0



122
123
124
125
126
 
# Arquivo 'lib/mongo/ servidor/monitor.rb', linha 122

def push_monitor
  @update_mutex.sincronizar fazer
    @push_monitor
  end
end

#reiniciar! ➤ Thread

Este método faz parte de uma API privada. Evite usar esse método, se possível, pois ele pode ser removido ou alterado no futuro.

Reinicia o monitor do servidor , a menos que o thread atual esteja vivo.

Exemplos:

Reinicie o monitor.

monitor.restart!

Retorna:

  • (Thread) —

    O thread em que o monitor é executado.

Desde:

  • 2.1.0



257
258
259
260
261
262
263
 
# Arquivo 'lib/mongo/ servidor/monitor.rb', linha 257

def reinicie!
  se @thread && @thread.alive?
    @thread
  mais
    corra!
  end
end

#run_sdam_flow(result, awaited: false, varredura_error: nil) ⇒ Object

Este método faz parte de uma API privada. Evite usar esse método, se possível, pois ele pode ser removido ou alterado no futuro.

Desde:

  • 2.0.0



223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
 
# Arquivo 'lib/mongo/ servidor/monitor.rb', linha 223

def run_sdam_flow(Resultado, esperado: false, varredura_error: nada)
  @sdam_mutex.sincronizar fazer
    old_description = Servidor.Descrição

    new_description = Descrição.Novo(
      Servidor.endereço,
      Resultado,
      average_round_trip_time: Servidor.round_trip_time_calculator.average_round_trip_time,
      minimum_round_trip_time: Servidor.round_trip_time_calculator.minimum_round_trip_time
    )

    Servidor.cluster.run_sdam_flow(Servidor.Descrição, new_description, esperado: esperado, varredura_error: varredura_error)

    Servidor.Descrição.toque fazer |new_description|
      a menos que esperado
        se new_description.desconhecido? && !old_description.desconhecido?
          @next_earlyest_scan = @next_Quered_scan = Hora.agora
        mais
          @next_earlyest_scan = Hora.agora + MIN_SCAN_INTERVAL
          @next_Quered_scan = Hora.agora + heartbeat_interval
        end
      end
    end
  end
end

#scan! ➤ Descrição

Este método faz parte de uma API privada. Evite usar esse método, se possível, pois ele pode ser removido ou alterado no futuro.

Observação:

Se o relógio do sistema se mover para trás, esse método poderá adormecido por um longo tempo.

Observação:

O valor de retorno deste método é preterido. Na versão 3.0.0 , este método não terá um valor de retorno.

Execute uma verificação do servidor com limitação e atualize a descrição do servidor e o tempo médio de ida e volta.

Se o servidor foi verificado há menos de MIN_SCAN_INTERVAL segundos, durma até que MIN_SCAN_INTERVAL segundos tenham se passado desde a última verificação. Em seguida, execute a verificação que envolve executar hello no servidor que está sendo monitorado e atualizar a descrição do servidor como resultado.

Retorna:

Desde:

  • 2.0.0



206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
 
# Arquivo 'lib/mongo/ servidor/monitor.rb', linha 206

def digitalizar!
  # Normalmente, o thread do background invocaria esse método.
  # Mas também é possível invocar varredura! diretamente em um monitor.
  # Permitir que apenas uma verificação seja realizada de cada vez.
  @mutex.sincronizar fazer
    acelerador_scan_frequency!

    começar
      Resultado = do_scan
    salvar StandardError => e
      run_sdam_flow({}, varredura_error: e)
    mais
      run_sdam_flow(Resultado)
    end
  end
end

#pare! ➤ verdadeiro | false

Interrompa o thread em background e aguarde até que ele encerre por um período de tempo razoável.

Retorna:

  • (verdadeiro | falso) —

    Se a conversa foi encerrada.

Desde:

  • 2.0.0



151
152
153
154
155
156
157
158
159
160
 
# Arquivo 'lib/mongo/ servidor/monitor.rb', linha 151

def pare!
  stop_push_monitor!

  # Encaminhar valor de retorno de super
  super.toque fazer
    # Importante: a desconexão deve ocorrer após a thread no background
    # termina.
    Conexão&.desconecte-se!
  end
end

#stop_push_monitor! ➤ Objeto

Este método faz parte de uma API privada. Evite usar esse método, se possível, pois ele pode ser removido ou alterado no futuro.

Desde:

  • 2.0.0



179
180
181
182
183
184
185
186
 
# Arquivo 'lib/mongo/ servidor/monitor.rb', linha 179

def stop_push_monitor!
  @update_mutex.sincronizar fazer
    se @push_monitor
      @push_monitor.pare!
      @push_monitor = nada
    end
  end
end

#to_s ➤ Objeto

Este método faz parte de uma API privada. Evite usar esse método, se possível, pois ele pode ser removido ou alterado no futuro.

Desde:

  • 2.0.0



265
266
267
 
# Arquivo 'lib/mongo/ servidor/monitor.rb', linha 265

def to_s
  "#<#{self.classe.name}:#{object_id} #{servidor.endereço}>"
end