跳至内容 跳至搜索

Active Storage Mirror 服务

包装一组镜像服务并提供一个 ActiveStorage::Service 对象，所有文件都将上传到该对象。指定一个 primary 服务来应答对以下内容的调用：

  • 下载

  • 是否存在？

  • 网址

  • 直接上传的网址

  • 直接上传的标头

方法
D
M
N
U

属性

[R] 镜像
[R] 主

类公共方法

new(primary:, mirrors:)

来源：显示 | 在 GitHub 上 

# File activestorage/lib/active_storage/service/mirror_service.rb, line 31
def initialize(primary:, mirrors:)
  @primary, @mirrors = primary, mirrors
end

实例公共方法

delete(key)

在所有服务上删除 key 处的文件。

来源：显示 | 在 GitHub 上 

# File activestorage/lib/active_storage/service/mirror_service.rb, line 45
def delete(key)
  perform_across_services :delete, key
end

delete_prefixed(prefix)

在所有服务上删除以 prefix 开头的键的文件。

来源：显示 | 在 GitHub 上 

# File activestorage/lib/active_storage/service/mirror_service.rb, line 50
def delete_prefixed(prefix)
  perform_across_services :delete_prefixed, prefix
end

mirror(key, checksum:)

将主服务中的 key 处文件复制到尚未存在该文件的每个镜像中。

来源：显示 | 在 GitHub 上 

# File activestorage/lib/active_storage/service/mirror_service.rb, line 59
def mirror(key, checksum:)
  instrument :mirror, key: key, checksum: checksum do
    if (mirrors_in_need_of_mirroring = mirrors.select { |service| !service.exist?(key) }).any?
      primary.open(key, checksum: checksum) do |io|
        mirrors_in_need_of_mirroring.each do |service|
          io.rewind
          service.upload key, io, checksum: checksum
        end
      end
    end
  end
end

upload(key, io, checksum: nil, **options)

将 io 上传到指定给所有服务的 key。上传到主服务是同步完成的，而上传到镜像是异步完成的。如果提供了 checksum，所有服务将在上传完成后确保匹配，否则会引发 ActiveStorage::IntegrityError。

来源：显示 | 在 GitHub 上 

# File activestorage/lib/active_storage/service/mirror_service.rb, line 38
def upload(key, io, checksum: nil, **options)
  io.rewind
  primary.upload key, io, checksum: checksum, **options
  mirror_later key, checksum: checksum
end