class

JoobQ::RedisPipeline

Inherits Reference / Object

Redis pipeline operations and performance tracking

Constructors

new(redis : Redis::PooledClient)
Source

Class methods

pipeline_stats
Source
reset_pipeline_stats
Source

Instance methods

batch_operations(operations : Array(Proc(Nil)), max_batch_size : Int32 = 10) : Nil

Connection reuse optimization: Batch multiple single operations into pipelines This reduces connection overhead for operations that don't need to be immediate

Source
cleanup_jobs_batch(job_jsons : Array(String), queue_name : String) : Nil

Batch job cleanup for high performance

Source
clear_queues_batch(queue_names : Array(String)) : Nil

Optimized method to clear multiple queues in a single pipeline

Source
execute_read_operations_batch(operations : Array( -> Redis::RedisValue)) : Array(Redis::RedisValue)

Connection pooling optimization: Execute multiple read operations in a single pipeline This is ideal for operations that can tolerate slightly stale data

Source
queue_sizes_batch(queue_names : Array(String)) : Hash(String, Int64)

Optimized batch queue sizes to reduce connection overhead

Source
set_sizes_batch(set_names : Array(String)) : Hash(String, Int64)

Optimized batch set sizes to reduce connection overhead

Source
track_pipeline_operation(commands_count : Int32, success : Bool) : Nil
Source

Nested types