Módulo: Mongo::Retryable
- Estendido por:
- Encaminhável
- Incluído em:
- Cluster::CursorReaper, Collection, Collection::View::aggregation, Collection::View::MapReduce, Cursor, banco de dados , Banco de dados::View, Índice::View, Servidor::Connection, Session
- Definido em:
- build/ruby-driver-v2.19/lib/mongo/retryable.rb,
build/ruby-driver-v2.19/lib/mongo/retryable/base_worker.rb,
build/ruby-driver-v2.19/lib/mongo/retryable/read_worker.rb,
build/ruby-driver-v2.19/lib/mongo/retryable/write_worker.rb
Visão geral
Define o comportamento básico em torno da repetição de operações.
Definido sob namespace
Classes: BaseWorker, ReadWorker, WriteWorker
Recolhimento do Resumo do método de instância
-
#read_worker ➤ Objeto
privado
Retorna o trabalhador de leitura para lidar com leituras repetíveis.
-
#select_server(cluster, server_selector, sessão) ➤ Mongo::Server
privado
Este é um método separado para possibilitar que o conjunto de testes afirme que a seleção do servidor é executada durante tentativas de repetição.
-
#write_worker ➤ Objeto
privado
Retorna o trabalhador de gravação para lidar com gravações repetíveis.
Detalhes do método de instância
#read_worker ➤ 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.
este é apenas um método público para que os testes possam adicionar expectativas com base nele.
Retorna o trabalhador de leitura para lidar com leituras repetíveis.
59 60 61 |
# File 'build/ruby-driver-v2.19/lib/mongo/retryable.rb', linha 59 def read_worker @read_worker ||= Read Worker.Novo(auto) end |
#select_server(cluster, server_selector, sessão) ➤ Mongo::Server
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.
Este é um método separado para possibilitar que o conjunto de testes afirme que a seleção do servidor é executada durante tentativas de repetição.
Este é um método público para que ele possa ser acessado por meio dos delegados de trabalho de leitura e escrita, conforme necessário.
49 50 51 |
# File 'build/ruby-driver-v2.19/lib/mongo/retryable.rb', linha 49 def select_server(cluster, server_selector, session) server_selector.select_server(cluster, nada, session) end |
#write_worker ➤ 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.
este é apenas um método público para que os testes possam adicionar expectativas com base nele.
Retorna o trabalhador de gravação para lidar com gravações repetíveis.
69 70 71 |
# File 'build/ruby-driver-v2.19/lib/mongo/retryable.rb', linha 69 def write_worker @write_worker ||= Write Worker.Novo(auto) end |