模块：Mongo::Retryable

扩展方式：
可转发
包含在：
Cluster::CursorReaper 、 Collection 、 Collection::View::Aggregation::Behavior 、 Collection::View::ChangeStream 、 Collection::View::MapReduce 、 Cursor 、 Database 、 Database::View 、 Index::View 、 SearchIndex: :View 、 Server::Connection 、 Session
定义于：
lib/ Mongo/retryable.rb 、
lib/ Mongo/retryable/base_worker.rb、
lib/ Mongo/retryable/read_worker.rb、
lib/ Mongo/retryable/write_worker.rb 更多...

Overview

定义有关重试操作的基本行为。

由于：

  • 2.1.0

在命名空间下定义

类： BaseWorker 、 ReadWorker 、 WriteWorker

实例方法摘要折叠

实例方法详细信息

# read_worker ⇒对象

此方法是私有 API 的一部分。 您应尽可能避免使用此方法，因为它将来可能会被删除或更改。

注意：

这只是一个公共方法，因此测试可以基于它添加期望。

返回用于处理可重试读取的读取工作线程。

由于：

  • 2.1.0

[查看源代码]

65
66
67
 
# File 'lib/ Mongo/retryable.rb', line 65

def read_worker
  @read_worker ||= ReadWorker.new(self)
end

# select_server (集群, server_selector, session, failed_server = nil, timeout: nil) ⇒ Mongo::Server

此方法是私有 API 的一部分。 您应尽可能避免使用此方法，因为它将来可能会被删除或更改。

这是一种单独的方法，使测试套件可以断言在重试尝试期间已执行服务器选择。

这是一个公共方法，因此可以根据需要通过读取和写入工作线程委托进行访问。

返回：

由于：

  • 2.1.0

[查看源代码]

49
50
51
52
53
54
55
56
57
 
# File 'lib/ Mongo/retryable.rb', line 49

def select_server(集群, server_selector, 会话, failed_server = nil, timeout: nil)
  server_selector.select_server(
    集群,
    nil,
    会话,
    取消优先级： [failed_server].compact,
    timeout: 超时
  )
end

# write_worker ⇒对象

此方法是私有 API 的一部分。 您应尽可能避免使用此方法，因为它将来可能会被删除或更改。

注意：

这只是一个公共方法，因此测试可以基于它添加期望。

返回用于处理可重试写入的写入工作线程。

由于：

  • 2.1.0

[查看源代码]

75
76
77
 
# File 'lib/ Mongo/retryable.rb', line 75

def write_worker
  @write_worker ||= WriteWorker.new(self)
end