module CapistranoMulticonfigParallel::BaseActorHelper::InstanceMethods
Public Instance Methods
setup_actor_supervision(class_name, options)
click to toggle source
# File lib/capistrano_multiconfig_parallel/helpers/base_actor_helper.rb, line 57 def setup_actor_supervision(class_name, options) if version_less_than_seventeen? class_name.supervise_as(*setup_actor_supervision_details(class_name, options)) else class_name.supervise setup_actor_supervision_details(class_name, options) end end
setup_actor_supervision_details(class_name, options)
click to toggle source
# File lib/capistrano_multiconfig_parallel/helpers/base_actor_helper.rb, line 46 def setup_actor_supervision_details(class_name, options) arguments = (options[:args].is_a?(Array) ? options[:args] : [options[:args]]).compact if version_less_than_seventeen? [options[:actor_name], options[:type], *arguments] else #supervises_opts = options[:supervises].present? ? { supervises: options[:supervises] } : {} { as: options[:actor_name], type: options[:type], args: arguments, size: options.fetch(:size, nil) } end end
setup_pool_of_actor(class_name, options)
click to toggle source
# File lib/capistrano_multiconfig_parallel/helpers/base_actor_helper.rb, line 73 def setup_pool_of_actor(class_name, options) if version_less_than_seventeen? class_name.pool(options[:type], as: options[:actor_name], size: options.fetch(:size, 10)) else # config = Celluloid::Supervision::Configuration.new # config.define setup_actor_supervision_details(class_name, options) options = setup_actor_supervision_details(class_name, options) class_name.pool *[options[:type], options.except(:type)] end end
setup_supervision_group()
click to toggle source
# File lib/capistrano_multiconfig_parallel/helpers/base_actor_helper.rb, line 65 def setup_supervision_group if version_less_than_seventeen? Celluloid::SupervisionGroup.run! else Celluloid::Supervision::Container.run! end end