#primary (readonly)
[ GitHub ]# File 'activestorage/lib/active_storage/service/mirror_service.rb', line 16
attr_reader :primary, :mirrors
123456789_123456789_123456789_123456789_123456789_
Relationships & Source Files | |
Super Chains via Extension / Inclusion / Inheritance | |
Class Chain:
|
|
Instance Chain:
self,
::ActiveStorage::Service
|
|
Inherits: |
ActiveStorage::Service
|
Defined in: | activestorage/lib/active_storage/service/mirror_service.rb |
Wraps a set of mirror services and provides a single ::ActiveStorage::Service
object that will all have the files uploaded to them. A #primary service is designated to answer calls to:
::ActiveStorage::Service
- Inherited.configure | Configure an Active Storage service by name from a set of configurations, typically loaded from a YAML file. |
::ActiveSupport::Autoload
- Extended::ActiveStorage::Service
- InheritedDelete the file at the key
on all services.
Delete files at keys starting with the prefix
on all services.
Copy the file at the key
from the primary service to each of the mirrors where it doesn’t already exist.
Upload the io
to the key
specified to all services.
::ActiveStorage::Service
- Inherited#compose | Concatenate multiple files into a single “composed” file. |
#delete | Delete the file at the |
#delete_prefixed | Delete files at keys starting with the |
#download | Return the content of the file at the |
#download_chunk | Return the partial content in the byte |
#exist? | Return |
#headers_for_direct_upload | Returns a |
#open, | |
#update_metadata | Update metadata for the file identified by |
#upload | Upload the |
#url | Returns the URL for the file at the |
#url_for_direct_upload | Returns a signed, temporary URL that a direct upload file can be PUT to on the |
MirrorService
# File 'activestorage/lib/active_storage/service/mirror_service.rb', line 18
delegate :download, :download_chunk, :exist?, :url, :url_for_direct_upload, :headers_for_direct_upload, :path_for, :compose, to: :primary
# File 'activestorage/lib/active_storage/service/mirror_service.rb', line 18
delegate :download, :download_chunk, :exist?, :url, :url_for_direct_upload, :headers_for_direct_upload, :path_for, :compose, to: :primary
# File 'activestorage/lib/active_storage/service/mirror_service.rb', line 18
delegate :download, :download_chunk, :exist?, :url, :url_for_direct_upload, :headers_for_direct_upload, :path_for, :compose, to: :primary
# File 'activestorage/lib/active_storage/service/mirror_service.rb', line 18
delegate :download, :download_chunk, :exist?, :url, :url_for_direct_upload, :headers_for_direct_upload, :path_for, :compose, to: :primary
# File 'activestorage/lib/active_storage/service/mirror_service.rb', line 16
attr_reader :primary, :mirrors
# File 'activestorage/lib/active_storage/service/mirror_service.rb', line 18
delegate :download, :download_chunk, :exist?, :url, :url_for_direct_upload, :headers_for_direct_upload, :path_for, :compose, to: :primary
# File 'activestorage/lib/active_storage/service/mirror_service.rb', line 16
attr_reader :primary, :mirrors
# File 'activestorage/lib/active_storage/service/mirror_service.rb', line 18
delegate :download, :download_chunk, :exist?, :url, :url_for_direct_upload, :headers_for_direct_upload, :path_for, :compose, to: :primary
# File 'activestorage/lib/active_storage/service/mirror_service.rb', line 18
delegate :download, :download_chunk, :exist?, :url, :url_for_direct_upload, :headers_for_direct_upload, :path_for, :compose, to: :primary
Delete the file at the key
on all services.
# File 'activestorage/lib/active_storage/service/mirror_service.rb', line 45
def delete(key) perform_across_services :delete, key end
Delete files at keys starting with the prefix
on all services.
# File 'activestorage/lib/active_storage/service/mirror_service.rb', line 50
def delete_prefixed(prefix) perform_across_services :delete_prefixed, prefix end
Boolean
# File 'activestorage/lib/active_storage/service/mirror_service.rb', line 18
delegate :download, :download_chunk, :exist?, :url, :url_for_direct_upload, :headers_for_direct_upload, :path_for, :compose, to: :primary
Copy the file at the key
from the primary service to each of the mirrors where it doesn’t already exist.
# 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 the io
to the key
specified to all services. The upload to the primary service is done synchronously whereas the upload to the mirrors is done asynchronously. If a checksum
is provided, all services will ensure a match when the upload has completed or raise an ::ActiveStorage::IntegrityError
.
# File 'activestorage/lib/active_storage/service/mirror_service.rb', line 38
def upload(key, io, checksum: nil, ** ) io.rewind primary.upload key, io, checksum: checksum, ** mirror_later key, checksum: checksum end