跳至內容 跳至搜尋

Active Storage Mirror 服務

包裹一組鏡像服務，並提供一個單一的 ActiveStorage::Service 物件，其中將包含所有已上傳至這些服務的檔案。指定一個 primary 服務來回傳對下列呼叫服務的資訊：

  • download

  • exists?

  • url

  • url_for_direct_upload

  • headers_for_direct_upload

方法
D
M
N
U

屬性

[R] mirrors
[R] primary

類別公開方法

new(primary:, mirrors:)

來源：顯示 | 在 GitHub 上

# File activestorage/lib/active_storage/service/mirror_service.rb, line 31
def initialize(primary:, mirrors:)
  @primary, @mirrors = primary, mirrors
  @executor = Concurrent::ThreadPoolExecutor.new(
    min_threads: 1,
    max_threads: mirrors.size,
    max_queue: 0,
    fallback_policy: :caller_runs,
    idle_time: 60
  )
end

執行個體公開方法

delete(key)

刪除在所有服務 key 處的檔案。

來源：顯示 | 在 GitHub 上

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

delete_prefixed(prefix)

刪除在所有服務中以 prefix 開頭的檔案。

來源：顯示 | 在 GitHub 上

# File activestorage/lib/active_storage/service/mirror_service.rb, line 57
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 66
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 45
def upload(key, io, checksum: nil, **options)
  io.rewind
  primary.upload key, io, checksum: checksum, **options
  mirror_later key, checksum: checksum
end