Módulo: Mongo::Retryable

Estendido por:
Encaminhável
Incluído em:
Cluster::CursorReaper, Collection, Collection::View::aggregation::Behavior, Collection::View::ChangeStream, Collection::View::MapReduce, Cursor, Banco de dados , Banco de dados::View , Index::View, SearchIndex: :Visualizar ,Servidor::Conexão , Sessão
Definido em:
lib/mongo/retryable.rb,
lib/mongo/retryable/base_worker.rb,
lib/mongo/retryable/read_worker.rb,
lib/mongo/retryable/write_worker.rb mais...

Visão geral

Define o comportamento básico em torno da repetição de operações.

Desde:

  • 2.1.0

Definido sob namespace

Classes: BaseWorker, ReadWorker, WriteWorker

Recolhimento do Resumo do método de instância

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.

Observação:

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.

Desde:

  • 2.1.0

[Ver fonte]

65
66
67
 
# Arquivo 'lib/mongo/retryable.rb', linha 65

def read_worker
  @read_worker ||= Read Worker.Novo(auto)
end

#select_server(cluster, server_selector, session, failed_server = nil, timeout: nil) ➤ 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.

Retorna:

  • (Mongo::Server) —

    Um servidor que corresponda à preferência do servidor .

Desde:

  • 2.1.0

[Ver fonte]

49
50
51
52
53
54
55
56
57
 
# Arquivo 'lib/mongo/retryable.rb', linha 49

def select_server(cluster, server_selector, session, failed_server = nada, timeout: nada)
  server_selector.select_server(
    cluster,
    nada,
    session,
    despriorizado: [failed_server].compactar,
    timeout: timeout
  )
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.

Observação:

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.

Desde:

  • 2.1.0

[Ver fonte]

75
76
77
 
# Arquivo 'lib/mongo/retryable.rb', linha 75

def write_worker
  @write_worker ||= Write Worker.Novo(auto)
end