class Mosquito::Runners::Overseer

• Mosquito::Runners::Overseer
• Reference
• Object

Overview

The Overseer is responsible for managing:

• a Coordinator
• an Executor
• the QueueList
• any idle state as configured

An overseer manages the loop that each thread or process runs.

Included Modules

• Mosquito::Runners::RunAtMost

Defined in:

mosquito/runners/overseer.cr

Constant Summary

Log = ::Log.for(self)

Constructors

• .new

Instance Method Summary

• #coordinator : Mosquito::Runners::Coordinator
• #executor : Mosquito::Runners::Executor
• #idle_wait : Time::Span

  Minimum time in seconds to wait between checking for jobs.

• #idle_wait=(idle_wait : Time::Span)

  Minimum time in seconds to wait between checking for jobs.

• #keep_running : Bool
• #keep_running=(keep_running : Bool)
• #queue_list : Mosquito::Runners::QueueList
• #run

  Runs the overseer workflow.

• #stop
• #tick
• #worker_id

Constructor Detail

Instance Method Detail