class
JoobQ::RedisPipeline
- JoobQ::RedisPipeline
- Reference
- Object
Overview
Redis pipeline operations and performance tracking
Defined in:
joobq/redis_pipeline.crConstructors
Class Method Summary
Instance Method Summary
-
#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
-
#cleanup_jobs_batch(job_jsons : Array(String), queue_name : String) : Nil
Batch job cleanup for high performance
-
#clear_queues_batch(queue_names : Array(String)) : Nil
Optimized method to clear multiple queues in a single pipeline
-
#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
-
#queue_sizes_batch(queue_names : Array(String)) : Hash(String, Int64)
Optimized batch queue sizes to reduce connection overhead
-
#set_sizes_batch(set_names : Array(String)) : Hash(String, Int64)
Optimized batch set sizes to reduce connection overhead
- #track_pipeline_operation(commands_count : Int32, success : Bool) : Nil
Constructor Detail
Class Method Detail
Instance Method Detail
Connection reuse optimization: Batch multiple single operations into pipelines This reduces connection overhead for operations that don't need to be immediate
Batch job cleanup for high performance
Optimized method to clear multiple queues in a single pipeline
Connection pooling optimization: Execute multiple read operations in a single pipeline This is ideal for operations that can tolerate slightly stale data
Optimized batch queue sizes to reduce connection overhead
Optimized batch set sizes to reduce connection overhead