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"

new(redis : Redis::PooledClient)

collect_statistics_batch

Optimized connection reuse for statistics collection

get_all_queue_metrics

Get metrics for all configured queues using pipelining

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

Optimized method to get job counts for multiple states at once

get_processing_jobs_count

Optimized method to get processing jobs count using Lua script

get_queue_metrics(queue_name : String) : QueueMetrics

Get metrics for a single queue

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

Get queue metrics for multiple queues using pipelining

get_retrying_jobs_count

Optimized retrying jobs count using Lua script for better performance

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

Optimized retrying jobs pagination using Lua script