module Redis::Stream::Inspect
Public Instance Methods
consumers(group = @group)
click to toggle source
# File lib/redis/stream/inspect.rb, line 20 def consumers(group = @group) @redis_pool.with do |redis| redis.xinfo("consumers", @stream, group) end end
del_consumer(group = @group, consumer = @consumer_id)
click to toggle source
# File lib/redis/stream/inspect.rb, line 26 def del_consumer(group = @group, consumer = @consumer_id) @logger.info("#{@consumer_id} - deleting consumer #{group}-#{consumer}") @redis_pool.with do |redis| redis.xgroup('DELCONSUMER', @stream, group, consumer) end end
del_group(group = @group)
click to toggle source
# File lib/redis/stream/inspect.rb, line 33 def del_group(group = @group) if consumers(group).length == 0 && groups.map { |m| m["name"] }.include?(group) @logger.info("#{@consumer_id} - deleting group #{group}") @redis_pool.with do |redis| redis.xgroup('DESTROY', @stream, group) end end end
groups()
click to toggle source
# File lib/redis/stream/inspect.rb, line 5 def groups @redis_pool.with do |redis| redis.xinfo("groups", @stream) end rescue Exception => e @logger.error("#{@consumer_id} - #{e.message}") {} end
info()
click to toggle source
# File lib/redis/stream/inspect.rb, line 14 def info @redis_pool.with do |redis| redis.xinfo("stream", @stream) end end
pending_messages()
click to toggle source
# File lib/redis/stream/inspect.rb, line 42 def pending_messages @redis_pool.with do |redis| redis.xrange(@stream) end end