class

JoobQ::RedisMetrics

Inherits Reference < Object

Redis metrics collection and statistics

Constants

DEAD_LETTER = "joobq:dead_letter"
DELAYED_SET = "joobq:delayed_jobs"
PROCESSING_QUEUE = "joobq:processing"

Constructors

new(redis : Redis::PooledClient)
Source

Instance methods

collect_statistics_batch

Optimized connection reuse for statistics collection

Source
get_all_queue_metrics

Get metrics for all configured queues using pipelining

Source
get_multiple_state_counts(states : Array(String)) : Hash(String, Int32)

Optimized method to get job counts for multiple states at once

Source
get_processing_jobs_count

Optimized method to get processing jobs count using Lua script

Source
get_queue_metrics(queue_name : String) : QueueMetrics

Get metrics for a single queue

Source
get_queue_metrics_pipelined(queue_names : Array(String)) : Hash(String, QueueMetrics)

Get queue metrics for multiple queues using pipelining

Source
get_retrying_jobs_count

Optimized retrying jobs count using Lua script for better performance

Source
get_retrying_jobs_paginated(page : Int32, per_page : Int32) : Array(String)

Optimized retrying jobs pagination using Lua script

Source
processing_depth(queue_name : String) : Int64

Jobs in processing for a queue across every process's own list (...:<queue>:<owner>) and the legacy shared list. A prefix SCAN also matches another queue whose name starts with this one, so each key is checked.

Source

Nested types