module Mosquito::Api

Defined in:

mosquito/api.cr
mosquito/api/concurrency_config.cr
mosquito/api/executor.cr
mosquito/api/job_run.cr

Class Method Summary

• .concurrency_config : ConcurrencyConfig

  Returns a ConcurrencyConfig instance for reading and writing the remotely stored concurrency limits used by RemoteConfigDequeueAdapter.

• .concurrency_limits(overseer_id : String) : Hash(String, Int32)

  Convenience reader for a specific overseer's concurrency limits.

• .concurrency_limits : Hash(String, Int32)

  Convenience reader for the current global remote concurrency limits.

• .event_receiver : Channel(Backend::BroadcastMessage)
• .executor(id : String) : Executor
• .executor_config : ExecutorConfig

  Returns an ExecutorConfig instance for reading and writing the remotely stored executor count.

• .executor_count(overseer_id : String) : Int32 | Nil

  Convenience reader for a specific overseer's executor count.

• .executor_count : Int32 | Nil

  Convenience reader for the global remote executor count.

• .job_run(id : String) : JobRun
• .list_overseers : Array(Overseer)
• .list_periodic_jobs : Array(PeriodicJob)
• .list_queues : Array(Observability::Queue)
• .overseer(id : String) : Overseer
• .set_concurrency_limits(limits : Hash(String, Int32), overseer_id : String) : Nil

  Convenience writer — replaces stored concurrency limits for a specific overseer.

• .set_concurrency_limits(limits : Hash(String, Int32)) : Nil

  Convenience writer — replaces the global stored concurrency limits so that all RemoteConfigDequeueAdapter instances pick them up on their next refresh cycle.

• .set_executor_count(count : Int32, overseer_id : String) : Nil

  Convenience writer — sets the executor count for a specific overseer.

• .set_executor_count(count : Int32) : Nil

  Convenience writer — sets the global executor count override.

Class Method Detail