класс ActiveStorage::Service::MirrorService

Родитель:: ActiveStorage::Service

Оборачивает набор сервисов-зеркал и предоставляет единый объект 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 29
def initialize(primary:, mirrors:)
  @primary, @mirrors = primary, mirrors
end

Публичные методы экземпляра

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

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

Удалить файл по ключу key на всех сервисах.

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

# File activestorage/lib/active_storage/service/mirror_service.rb, line 48
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 54
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 35
def upload(key, io, checksum: nil, **options)
  each_service.collect do |service|
    io.rewind
    service.upload key, io, checksum: checksum, **options
  end
end

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