class Mosquito::Configuration

Defined in:

mosquito/configuration.cr

Instance Method Summary

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 overseer_id : String | Nil #

A stable, user-chosen identifier for this overseer instance. Used to look up per-overseer remote configuration (executor count, concurrency limits, etc.). When nil, the overseer only reads global remote config.


def overseer_id=(overseer_id : String | Nil) #

A stable, user-chosen identifier for this overseer instance. Used to look up per-overseer remote configuration (executor count, concurrency limits, etc.). When nil, the overseer only reads global remote config.


def publish_metrics : Bool #

def publish_metrics=(publish_metrics : Bool) #

def resource_gates : Hash(String, Mosquito::ResourceGate) #

Maps queue names to resource gates. Queues whose gate returns false from #allow? are excluded from dequeuing.


def resource_gates=(resource_gates : Hash(String, Mosquito::ResourceGate)) #

Maps queue names to resource gates. Queues whose gate returns false from #allow? are excluded from dequeuing.


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) #