Módulo: Mongo::Retryable

Ampliado por:
Reenviable
Incluido en:
Cluster::CursorReaper, Colección, Colección::Vista::Agregación::Comportamiento, Colección::Vista::Flujo de cambios, Colección::Vista::MapReduce, Cursor,Base de datos, Base de datos::Vista, Índice::Vista, Índice debúsqueda::Vista, Servidor::Conexión, Sesión
Definido en:
lib/mongo/retryable.rb,
lib/mongo/retryable/base_worker.rb,
lib/mongo/retryable/read_worker.rb,
lib/mongo/retryable/write_worker.rb

Overview

Define el comportamiento básico en torno a las operaciones de reintento.

Desde:

  • 2.1.0

Definido en el espacio de nombres

Clases: BaseWorker, ReadWorker, WriteWorker

Colapso del resumen del método de instancia

Detalles del método de instancia

#read_worker ⇒ 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.

Nota:

Este es solo un método público para que las pruebas puedan agregar expectativas basadas en él.

Devuelve el trabajador de lectura para manejar lecturas que se pueden volver a intentar.

Desde:

  • 2.1.0



65
66
67
 
# Archivo 'lib/mongo/retryable.rb', línea 65

def read_worker
  @read_worker ||= Trabajador de lectura.Nuevo(yo)
end

#select_server(clúster, selector_de_servidor, sesión, servidor_fallido = nulo, tiempo de espera: nulo) ⇒ Mongo::Server

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

Este es un método separado que permite que el conjunto de pruebas afirme que la selección del servidor se realiza durante los intentos de reintento.

Este es un método público, por lo que se puede acceder a él a través de los delegados de trabajo de lectura y escritura, según sea necesario.

Devuelve:

  • (Mongo::Servidor) —

    Un servidor que coincide con la preferencia del servidor.

Desde:

  • 2.1.0



49
50
51
52
53
54
55
56
57
 
# Archivo 'lib/mongo/retryable.rb', línea 49

def seleccionar_servidor(clúster, selector de servidor, sesión, servidor fallido = nulo, timeout: nulo)
  selector de servidor.seleccionar_servidor(
    clúster,
    nulo,
    sesión,
    despriorizado: [servidor fallido].compact,
    timeout: tiempo de espera
  )
end

#write_worker ⇒ 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.

Nota:

Este es solo un método público para que las pruebas puedan agregar expectativas basadas en él.

Devuelve el trabajador de escritura para manejar escrituras reintentables.

Desde:

  • 2.1.0



75
76
77
 
# Archivo 'lib/mongo/retryable.rb', línea 75

def write_worker
  @write_worker ||= Trabajador de escritura.Nuevo(yo)
end