class Maxwell::Agent::Runner
Attributes
registry[R]
Public Class Methods
new(opts)
click to toggle source
Calls superclass method
# File lib/maxwell/agent/runner.rb, line 18 def initialize(opts) super pool Agent::MiddlewareRunner, size: self.class.worker_pool_size supervise_as :work_schedule, Agent::WorkSchedule pool Agent::StandardWorker, as: :worker, size: self.class.worker_pool_size supervise_as :evented_worker, Agent::EventedWorker supervise_as :scheduler, Agent::Scheduler, work_schedule: self[:work_schedule], worker: self[:worker], evented_worker: self[:evented_worker] self[:scheduler].async.run end
worker_pool_size()
click to toggle source
# File lib/maxwell/agent/runner.rb, line 14 def self.worker_pool_size Agent.configuration.worker_concurrency end
Public Instance Methods
[](actor_name)
click to toggle source
# File lib/maxwell/agent/runner.rb, line 35 def [](actor_name) @registry[actor_name] end