class JoobQ::RedisMetrics

• JoobQ::RedisMetrics
• Reference
• Object

Overview

Redis metrics collection and statistics

Defined in:

joobq/redis_metrics.cr

Constant Summary

DEAD_LETTER = "joobq:dead_letter"

DELAYED_SET = "joobq:delayed_jobs"

PROCESSING_QUEUE = "joobq:processing"

Constructors

• .new(redis : Redis::PooledClient)

Instance Method Summary

• #collect_statistics_batch : Hash(String, Int64)

  Optimized connection reuse for statistics collection

• #get_all_queue_metrics : Hash(String, QueueMetrics)

  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 : Int32

  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 : Int32

  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

Constructor Detail

Instance Method Detail