class Mosquito::Runner

Defined in:

mosquito/runner.cr

Constant Summary

Log = ::Log.for(self)

Constructors

Class Method Summary

Instance Method Summary

Constructor Detail

def self.new #

[View source]

Class Method Detail

def self.keep_running : Bool #

Should the worker continue working?


[View source]
def self.keep_running=(keep_running : Bool) #

Should the worker continue working?


[View source]
def self.start #

[View source]
def self.stop #

[View source]

Instance Method Detail

def failed_job_ttl : Int32 #

How long a job config is persisted after failure


[View source]
def failed_job_ttl=(failed_job_ttl : Int32) #

How long a job config is persisted after failure


[View source]
def idle_wait : Float64 #

Minimum time in seconds to wait between checking for jobs.


[View source]
def idle_wait=(idle_wait : Float64) #

Minimum time in seconds to wait between checking for jobs.


[View source]
def queues : Array(Mosquito::Queue) #

[View source]
def run #

[View source]
def start_time : Int64 #

[View source]
def successful_job_ttl : Int32 #

How long a job config is persisted after success


[View source]
def successful_job_ttl=(successful_job_ttl : Int32) #

How long a job config is persisted after success


[View source]