class Mosquito::Configuration

Mosquito::Configuration
Reference
Object

Defined in:

mosquito/configuration.cr

Instance Method Summary

#backend : Mosquito::Backend
#backend=(backend : Mosquito::Backend)
#backend_connection
#backend_connection_string
#backend_connection_string=(value : String)
#dead_overseer_threshold : Time::Span
How long an overseer can go without a heartbeat before it is considered dead and its pending jobs are recovered.
#dead_overseer_threshold=(dead_overseer_threshold : Time::Span)
How long an overseer can go without a heartbeat before it is considered dead and its pending jobs are recovered.
#dequeue_adapter : Mosquito::DequeueAdapter
#dequeue_adapter=(dequeue_adapter : Mosquito::DequeueAdapter)
#executor_count : Int32
#executor_count=(executor_count : Int32)
#failed_job_ttl : Int32
#failed_job_ttl=(failed_job_ttl : Int32)
#global_prefix : String | Nil
#global_prefix=(global_prefix : String | Nil)
#heartbeat_interval : Time::Span
How often a mosquito runner should emit a heartbeat metric.
#heartbeat_interval=(heartbeat_interval : Time::Span)
How often a mosquito runner should emit a heartbeat metric.
#idle_wait : Time::Span
#idle_wait=(idle_wait : Time::Span)
#idle_wait=(time_span : Float)
#metrics? : Bool
#publish_metrics : Bool
#publish_metrics=(publish_metrics : Bool)
#run_from : Array(String)
#run_from=(run_from : Array(String))
#successful_job_ttl : Int32
#successful_job_ttl=(successful_job_ttl : Int32)
#use_distributed_lock : Bool
#use_distributed_lock=(use_distributed_lock : Bool)
#validate
#validated : Bool
#validated=(validated : Bool)

Instance Method Detail

def backend : Mosquito::Backend #

def backend=(backend : Mosquito::Backend) #

def backend_connection #

def backend_connection_string #

def backend_connection_string=(value : String) #

def dead_overseer_threshold : Time::Span #

How long an overseer can go without a heartbeat before it is considered dead and its pending jobs are recovered.

def dead_overseer_threshold=(dead_overseer_threshold : Time::Span) #

How long an overseer can go without a heartbeat before it is considered dead and its pending jobs are recovered.

def dequeue_adapter : Mosquito::DequeueAdapter #

def dequeue_adapter=(dequeue_adapter : Mosquito::DequeueAdapter) #

def executor_count : Int32 #

def executor_count=(executor_count : Int32) #

def failed_job_ttl : Int32 #

def failed_job_ttl=(failed_job_ttl : Int32) #

def global_prefix : String | Nil #

def global_prefix=(global_prefix : String | Nil) #

def heartbeat_interval : Time::Span #

How often a mosquito runner should emit a heartbeat metric.

def heartbeat_interval=(heartbeat_interval : Time::Span) #

How often a mosquito runner should emit a heartbeat metric.

def idle_wait : Time::Span #

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

def idle_wait=(time_span : Float) #

def metrics? : Bool #

def publish_metrics : Bool #

def publish_metrics=(publish_metrics : Bool) #

def run_from : Array(String) #

def run_from=(run_from : Array(String)) #

def successful_job_ttl : Int32 #

def successful_job_ttl=(successful_job_ttl : Int32) #

def use_distributed_lock : Bool #

def use_distributed_lock=(use_distributed_lock : Bool) #

def validate #

def validated : Bool #

def validated=(validated : Bool) #