Module: Esse::RedisStorage::QueueStats

Extended by:

Forwardable

Defined in:

lib/esse/redis_storage/queue_stats.rb

Constant Summary

KEY =

"#{Esse::RedisStorage::NAMESPACE}:queues"

Class Method Summary

• .all ⇒ Object
• .clear ⇒ Object
• .delete(value) ⇒ Object
• .push(value) ⇒ Object

Class Method Details

.all ⇒ Object

# File 'lib/esse/redis_storage/queue_stats.rb', line 12

def all
  with { |conn| conn.smembers(KEY) }
end

.clear ⇒ Object

# File 'lib/esse/redis_storage/queue_stats.rb', line 24

def clear
  with { |conn| conn.del(KEY) }
end

.delete(value) ⇒ Object

# File 'lib/esse/redis_storage/queue_stats.rb', line 20

def delete(value)
  with { |conn| conn.srem(KEY, value) }
end

.push(value) ⇒ Object

# File 'lib/esse/redis_storage/queue_stats.rb', line 16

def push(value)
  with { |conn| conn.sadd(KEY, value) }
end