Clase: Mongo::ServerSelector::Base

Hereda:
Objeto
  • Objeto
Mostrar todo
Definido en:
lib/mongo/server_selector/base.rb

Overview

Desde:

  • 2.0.0

Resumen de atributos de la instancia colapsar

Resumen del método de instancia colapsar

Detalles del Constructor

#initialize(options = nil) ⇒ Base

Este método es parte de una API privada. Se debe evitar el uso de este método si es posible, ya que podría eliminarse o modificarse en el futuro.

Inicializa el selector de servidores.

Ejemplos:

Inicializa el selector.

Mongo::ServerSelector::Secondary.new(:tag_sets => [{'dc' => 'nyc'}])

Inicializar la preferencia sin opciones.

Mongo::ServerSelector::Secondary.new

Parámetros:

  • opciones (encriptada) (valor por defecto: nil) —

    Las opciones de preferencia del servidor.

Opciones Hash (options):

  • :local_threshold (Integer) —

    El límite del umbral local para la selección más cercana en segundos.

  • max_staleness (Integer) —

    El atraso de la replicación máximo, en segundos, que un secundario puede soportar y aún así ser elegible para una lectura. Un valor de -1 se trata de la misma manera que nil, que es no tener una obsolescencia máxima.

  • :hedge (Hash | nil) —

    Una encriptada que especifica si se deben habilitar las lecturas protegidas en el servidor. Las lecturas protegidas no están habilitadas por defecto. Al especificar esta opción, debe tener el formato: { enabled: true }, donde el valor de la clave :enabled es un valor booleano. @deprecated Las lecturas protegidas están en desuso en MongoDB Server 8.0 y se eliminarán en una versión futura.

Aumenta:

Desde:

  • 2.0.0



47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
 
# Archivo 'lib/mongo/server_selector/base.rb', línea 47

def inicializar(opciones = nulo)
  opciones = opciones ? opciones.dup : {}
  opciones.borrar(max_staleness) si opciones[max_staleness] == -1
  @options = opciones
  @tag_sets = opciones[Conjuntos de etiquetas] || []
  @max_staleness = opciones[max_staleness]
  @hedge = opciones[:hedge]

  validate!

  return si @hedge.nil?

  mongo::Obsolescencias.advertencia(
    :hedge_read_preference,
    'La opción de preferencia de lectura protegida está en desuso. Las lecturas protegidas están ' \
    'en desuso en MongoDB Server 8.0 y se eliminarán en una versión futura.'
  )
end

Detalles de atributo de instancias

#hedge ⇒ hash | nil (solo lectura)

Obsoleto.

Las lecturas protegidas están en desuso en MongoDB Server 8.0 y se eliminarán en una versión futura.

Devuelve hedge El documento que especifica si se debe habilitar lecturas protegidas.

Devuelve:

  • (Hash | nil) —

    Cobertura El documento que especifica si se habilitan las lecturas protegidas.

Desde:

  • 2.0.0



83
84
85
 
# Archivo 'lib/mongo/server_selector/base.rb', línea 83

def hedge
  @hedge
end

#max_staleness ⇒ Integer (solo lectura)

Devuelve max_staleness El máximo atraso de la replicación, en segundos, que un secundario puede experimentar y aún ser elegible para una lectura.

Devuelve:

  • (Número entero) —

    max_staleness El atraso de la replicación máximo, en segundos, que puede presentarse en un secundario y que aún lo haga elegible para una lectura.

Desde:

  • 2.4.0



76
77
78
 
# Archivo 'lib/mongo/server_selector/base.rb', línea 76

def max_staleness
  @max_staleness
end

#opciones ⇒ Hash (solo lectura)

Devuelve opciones Las opciones.

Devuelve:

  • (encriptada) —

    opciones Las opciones.

Desde:

  • 2.0.0



67
68
69
 
# Archivo 'lib/mongo/server_selector/base.rb', línea 67

def opciones
  @options
end

#tag_sets ⇒ arreglo (solo lectura)

Devuelve tag_sets Los conjuntos de etiquetas utilizados para seleccionar servidores.

Devuelve:

  • (arreglo) —

    Conjuntos de etiquetas Los conjuntos de etiquetas utilizados para seleccionar servidores.

Desde:

  • 2.0.0



70
71
72
 
# Archivo 'lib/mongo/server_selector/base.rb', línea 70

def tag_sets
  @tag_sets
end

Detalles del método de instancia

#==(otro) ⇒ true, false

Comprueba la igualdad de dos selectores de servidor.

Ejemplos:

Compruebe la igualdad de los selectores de servidor.

preference == other

Parámetros:

  • Otros (objeto) —

    La otra preferencia.

Devuelve:

  • (true, false) —

    Si los objetos son iguales.

Desde:

  • 2.0.0



143
144
145
146
 
# Archivo 'lib/mongo/server_selector/base.rb', línea 143

def ==(Otros)
  Nombre == Otros.Nombre && hedge == Otros.hedge &&
    max_staleness == Otros.max_staleness && tag_sets == Otros.tag_sets
end

#candidatos(clúster, despriorizados = []) ⇒ arreglo<servidor>

Este método es parte de una API privada. Se debe evitar el uso de este método si es posible, ya que podría eliminarse o modificarse en el futuro.

Devuelve servidores de tipos aceptables desde el clúster.

No realiza validación de obsolescencia, filtrado de obsolescencia o filtrado de latencia.

Parámetros:

  • clúster (clúster) —

    El clúster.

  • rebajado de prioridad (Array<servidor>) (valor por defecto: []) —

    Una lista de servidores que solo debe seleccionarse si no hay otros servidores disponibles.

Devuelve:

  • (Array<servidor>) —

    Los servidores candidatos.

Desde:

  • 2.0.0



399
400
401
402
403
404
405
406
407
408
409
 
# Archivo 'lib/mongo/server_selector/base.rb', línea 399

def candidatos(clúster, rebajado de prioridad = [])
  servidor = clúster.servidor.rechazar { |s| rebajado de prioridad.incluir?(s) }
  si clúster.¿Soltero/a? || clúster.particionado?
    servidor
  elsif clúster.replica_set?
    select_in_replica_set(servidor)
  else
    # Clúster desconocido - sin servidores
    []
  end
end

#inspect ⇒ String

Inspecciona el selector de servidor.

Ejemplos:

Inspecciona el selector de servidor.

selector.inspect

Devuelve:

  • (string) —

    La inspección.

Desde:

  • 2.2.0



129
130
131
 
# Archivo 'lib/mongo/server_selector/base.rb', línea 129

def inspeccionar
  "#<#{self.class.name}:0x#{object_id} tag_sets=#{tag_sets.inspect} max_staleness=#{max_staleness.inspect} hedge=#{hedge}>"
end

#local_threshold ⇒ Float

Obsoleto.

Ahora se toma esta configuración de las opciones del clúster cuando se selecciona un servidor. Se eliminará en la versión 3.0.

Obtenga el límite del umbral local para la selección más cercana en segundos.

Ejemplos:

Obtenga el umbral local.

selector.local_threshold

Devuelve:

  • (Float) —

    El umbral local.

Desde:

  • 2.0.0



112
113
114
 
# Archivo 'lib/mongo/server_selector/base.rb', línea 112

def umbral_local
  @local_threshold ||= opciones[:local_threshold] || ServerSelector::UMBRAL_LOCAL
end

#local_threshold_with_cluster(clúster) ⇒ Objeto

Este método es parte de una API privada. Se debe evitar el uso de este método si es posible, ya que podría eliminarse o modificarse en el futuro.

Desde:

  • 2.0.0



117
118
119
 
# Archivo 'lib/mongo/server_selector/base.rb', línea 117

def local_threshold_with_cluster(clúster)
  opciones[:local_threshold] || clúster.opciones[:local_threshold] || UMBRAL_LOCAL
end

#select_server(clúster, ping = nil, session = nil, write_aggregation: false, deprioritized: [], timeout: nil) ⇒ Mongo::Servidor

Selecciona un servidor del clúster especificado, teniendo en cuenta el pinning de mongos para la sesión especificada.

Si la sesión está dada y tiene un servidor fijado, este servidor es el único considerado para la selección. Si el servidor es de tipo mongos, se devuelve inmediatamente; de lo contrario, se inician comprobaciones de supervisión en este servidor para actualizar su estado, y si el servidor se convierte en un mongos dentro del tiempo de espera de selección de servidor, se devuelve.

Si no se especifica una sesión o la sesión no tiene un servidor fijado, se realiza el proceso normal de selección de servidor entre todos los servidores en el clúster especificado que coincidan con la preferencia de este objeto selector de servidores. Los chequeos de supervisión se inician en los servidores del clúster hasta que se encuentra un servidor adecuado, hasta agotarse el tiempo de espera para la selección del servidor.

Si no se encuentra un servidor adecuado dentro del tiempo de espera de selección de servidor, este método arroja Error::NoServerAvailable.

Parámetros:

  • clúster (Mongo::clúster) —

    El clúster del que seleccionar un servidor elegible.

  • ping (verdadero, falso) (valor por defecto: nil) —

    Indica si se realiza un ping al servidor antes de la selección. Obsoleto e ignorado.

  • sesión (Session | nil) (valor por defecto: nil) —

    Sesión opcional para tener en cuenta el pinning de mongos.

  • escribir_agregación (true | false) (por defecto: false) —

    Si necesitamos un servidor que admita la escritura de agregaciones (por ejemplo, con $merge/$out) en los secundarios.

  • rebajado de prioridad (Array<servidor>) (valor por defecto: []) —

    Una lista de servidores que solo debe seleccionarse si no hay otros servidores disponibles.

  • :timeout (Float | nil) —

    Tiempo de espera en segundos para la operación, si existen.

Devuelve:

  • (Mongo::servidor)  —

    Un servidor que coincida con la preferencia del servidor.

Aumenta:

  • (Error::NoServerAvailable) —

    No se encontró ningún servidor que cumpla con la preferencia especificada o el requisito de fijación dentro del tiempo de espera de selección del servidor.

  • (Error::LintError) —

    Se ha detectado una condición inesperada y el modo lint está activado.

Desde:

  • 2.0.0



189
190
191
192
193
194
195
196
197
198
199
200
201
202
 
# Archivo 'lib/mongo/server_selector/base.rb', línea 189

def select_server(
  clúster,
  ping = nulo,
  sesión = nulo,
  escribir_agrupacion: false,
  con menor prioridad: [],
  timeout: nulo
)
  select_server_impl(clúster, ping, sesión, escribir_agregación, rebajado de prioridad, tiempo de espera).tocar hacer |Server|
    si Lint.¿habilitado? && !Server.group.¿Listo?
      propagar Error::LintError, 'Selector de servidor devolviendo un servidor con un conjunto que no está listo'
    end
  end
end

#servidor_selección_tiempo_fuera ⇒ Flotante

Obsoleto.

Ahora se toma esta configuración de las opciones del clúster cuando se selecciona un servidor. Se eliminará en la versión 3.0.

Obtener el tiempo de espera para la selección del servidor.

Ejemplos:

Obtenga el tiempo de espera para la selección del servidor, en segundos.

selector.server_selection_timeout

Devuelve:

  • (Float) —

    El tiempo de espera.

Desde:

  • 2.0.0



96
97
98
99
 
# Archivo 'lib/mongo/server_selector/base.rb', línea 96

def server_selection_timeout
  @server_selection_timeout ||=
    opciones[:server_selection_timeout] || ServerSelector::SERVER_SELECTION_TIMEOUT
end

#servicios_apropiados(clúster, anulados = []) ⇒ arreglo<Servidor>

Este método es parte de una API privada. Se debe evitar el uso de este método si es posible, ya que podría eliminarse o modificarse en el futuro.

Devuelve servidores que cumplan con el selector de servidores del clúster.

Parámetros:

  • clúster (clúster) —

    El clúster.

  • rebajado de prioridad (Array<servidor>) (valor por defecto: []) —

    Una lista de servidores que solo debe seleccionarse si no hay otros servidores disponibles.

Devuelve:

  • (Array<servidor>) —

    Los servidores adecuados.

Desde:

  • 2.0.0



420
421
422
423
424
 
# Archivo 'lib/mongo/server_selector/base.rb', línea 420

def servidores_adecuados(clúster, rebajado de prioridad = [])
  Resultado = adecuado_servidores_impl(clúster, rebajado de prioridad)
  Resultado = adecuado_servidores_impl(clúster, []) si Resultado.¿vacío? && rebajado de prioridad.any?
  Resultado
end

#try_select_server(cluster, write_aggregation: false, deprioritized: []) ⇒ Servidor | nil

Este método es parte de una API privada. Se debe evitar el uso de este método si es posible, ya que podría eliminarse o modificarse en el futuro.

Intenta encontrar un servidor adecuado, devuelve el servidor si hay uno disponible o nil si no hay un servidor adecuado.

Parámetros:

  • clúster (Mongo::clúster) —

    El clúster del que seleccionar un servidor elegible.

  • escribir_agregación (true | false) (por defecto: false) —

    Si necesitamos un servidor que admita la escritura de agregaciones (por ejemplo, con $merge/$out) en los secundarios.

  • rebajado de prioridad (Array<servidor>) (valor por defecto: []) —

    Una lista de servidores que se deben seleccionar solo si no hay otros servidores disponibles. Esto se usa para evitar seleccionar el mismo servidor dos veces seguidas al reintentar un comando.

Devuelve:

  • (Server | nil) —

    Un servidor adecuado, si existe.

Desde:

  • 2.0.0



350
351
352
353
354
355
356
357
358
359
360
361
362
363
364
365
366
367
368
369
370
371
372
373
374
375
376
377
378
379
380
381
382
383
384
385
 
# Archivo 'lib/mongo/server_selector/base.rb', línea 350

def try_select_server(clúster, escribir_agrupacion: false, con menor prioridad: [])
  servidor = si escribir_agregación && clúster.replica_set?
              # 1. Verifique si TODOS los servidores en el clúster admiten guardado secundario.
              is_write_supported = clúster.servidor.disminuir(true) hacer |res, Server|
                res && Server.Funcionalidades.merge_out_on_secondary_enabled?
              end

              si is_write_supported
                # 2. Si todos los servidores admiten escrituras secundarias, respetamos la preferencia de lectura.
                servidores_adecuados(clúster, rebajado de prioridad)
              else
                # 3. De lo contrario, recurrimos al primario para el set de réplicas.
                [ clúster.servidor.detectar(&primario/a?) ]
              end
            else
              servidores_adecuados(clúster, rebajado de prioridad)
            end

  # Esta lista de servidores puede ordenarse de una manera específica
  # por el selector (por ejemplo, para secundario preferente, el primero
  el servidor # puede ser secundario y el segundo servidor puede ser primario)
  # y deberíamos tomar el primer servidor aquí respetando el orden
  Server = servidor_adecuado(servidor)

  si Server && Lint.¿habilitado? && Server.average_round_trip_time.nil?
    # Es posible que un servidor tenga un RTT promedio nulo aquí
    # porque el ARTT proviene de una descripción que puede actualizarse
    # por un hilo en segundo plano mientras se ejecuta la selección del servidor.
    # Actualmente, el modo lint no es una funcionalidad pública, si/cuando lo sea
    # cambios (https://jira.mongodb.org/browse/RUBY-1576) el/la
    # sería necesario eliminar el requisito para que ARTT no sea nulo.
    propagar Error::LintError, "Servidor #{servidor.dirección} tiene rtt promedio nulo"
  end

  Server
end