class ActiveStorage::Service::MirrorService

Родительский класс:: ActiveStorage::Service

Служба зеркалирования Active Storage

Оборачивает набор служб-зеркал и предоставляет единый объект ActiveStorage::Service, в который будут загружаться файлы. Служба primary отвечает на вызовы:

download
exists?
url
url_for_direct_upload
headers_for_direct_upload

Атрибуты

mirrors [R]

primary [R]

Открытые методы класса

new (primary:, mirrors:) Показать исходный код

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

Открытые методы экземпляра

delete (key) Показать исходный код

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

Удаляет файл с ключом key во всех службах.

delete_prefixed (prefix) Показать исходный код

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

Удаляет во всех службах файлы с ключами, начинающимися с prefix.

mirror (key, checksum:) Показать исходный код

# 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

Копирует файл с ключом key из основной службы в каждую службу-зеркало, где его ещё нет.

upload (key, io, checksum: nil, **options) Показать исходный код

# 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

Загружает io по key, указанному для всех служб. Загрузка в основную службу выполняется синхронно, а в службы-зеркала — асинхронно. Если задан checksum, все службы проверят соответствие после завершения загрузки или вызовут исключение ActiveStorage::IntegrityError.