class Mosquito::Runner

Defined in:

mosquito/runner.cr

Constructors

Class Method Summary

Instance Method Summary

Constructor Detail

def self.new #

[View source]

Class Method Detail

def self.idle_wait=(idle_wait) #

Message to be removed after version 0.12.0


[View source]
def self.start #

[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 in redis.


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

Minimum time in seconds to wait between checking for jobs in redis.


[View source]
def idle_wait=(time_span : Time::Span) #

[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]