class JoobQ::GlobalStats

Overview

Class to aggregate global statistics

Included Modules

Defined in:

joobq/global_stats.cr

Constructors

Class Method Summary

Instance Method Summary

Class methods inherited from module JoobQ::StatsUtils

format_latency(latency_in_seconds : Float64) : String format_latency, percent_of(value : Number, total : Number) : Float64 percent_of

Constructor Detail

def self.new(metrics_provider : MetricsProvider = QueueMetrics.instance) #

[View source]

Class Method Detail

def self.instance #

[View source]

Instance Method Detail

def average_jobs_in_flight : Float64 #

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

[View source]
def calculate_stats #

Calculate global statistics using a metrics provider


[View source]
def completed : Int64 #

[View source]
def completed=(completed : Int64) #

[View source]
def current_size : Int64 #

[View source]
def current_size=(current_size : Int64) #

[View source]
def dead : Int64 #

[View source]
def dead=(dead : Int64) #

[View source]
def error_rate_trend : Float64 #

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

[View source]
def errors_per_second : Float64 #

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

[View source]
def failed_job_rate : Float64 #

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

[View source]
def job_execution_time : Float64 #

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

[View source]
def job_wait_time : Float64 #

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

[View source]
def jobs_completed_per_second : Float64 #

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

[View source]
def overtime_series : OvertimeSeries #

[View source]
def overtime_series=(overtime_series : OvertimeSeries) #

[View source]
def queue_reduction_rate : Float64 #

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

[View source]
def retried : Int64 #

[View source]
def retried=(retried : Int64) #

[View source]
def running_workers : Int64 #

[View source]
def running_workers=(running_workers : Int64) #

[View source]
def stats #

[View source]
def total_workers : Int64 #

Define properties for all the stats


[View source]
def total_workers=(total_workers : Int64) #

Define properties for all the stats


[View source]
def worker_utilization : Float64 #

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

[View source]