Method: ActiveStorage::Service::MirrorService#initialize

Defined in:
lib/active_storage/service/mirror_service.rb

#initialize(primary:, mirrors:) ⇒ MirrorService

Returns a new instance of MirrorService.



31
32
33
34
35
36
37
38
39
40
 
# File '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