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