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