模块：Mongo::Retryable

扩展方式：
可转发
包含在：
Cluster::CursorReaper 、 Collection 、 Collection::View::Aggregation 、 Collection::View::MapReduce 、游标、 Database 、 Database::View 、 Index::View 、 Server::Connection 、 Session
定义于：
构建/ruby-driver-v2.19/lib/ mongo /retryable.rb 、
构建/ruby-driver-v2.19/lib/ mongo /retryable/base_worker.rb,
构建/ruby-driver-v2.19/lib/ mongo /retryable/read_worker.rb,
构建/ruby-driver-v2.19/lib/ mongo /retryable/write_worker.rb

Overview

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

由于：

  • 2.1.0

在命名空间下定义

类： BaseWorker 、 ReadWorker 、 WriteWorker

实例方法摘要折叠

实例方法详细信息

# read_worker ⇒对象

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

注意：

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

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

由于：

  • 2.1.0



59
60
61
 
# File ' 构建/ruby-driver-v2.19/lib/ mongo /retryable.rb', line 59

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

# select_server (集群, server_selector, session) ⇒ Mongo::Server

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

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

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

返回：

由于：

  • 2.1.0



49
50
51
 
# File ' 构建/ruby-driver-v2.19/lib/ mongo /retryable.rb', line 49

def select_server(集群, server_selector, 会话)
  server_selector.select_server(集群, nil, 会话)
end

# write_worker ⇒对象

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

注意：

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

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

由于：

  • 2.1.0



69
70
71
 
# File ' 构建/ruby-driver-v2.19/lib/ mongo /retryable.rb', line 69

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