class Octokiq::Connection
Attributes
redis[RW]
Public Class Methods
new()
click to toggle source
# File lib/octokiq/connection.rb, line 8 def initialize @redis = Redis.new end
Public Instance Methods
fetch(queues)
click to toggle source
# File lib/octokiq/connection.rb, line 12 def fetch(queues) _, job = redis.blpop(*build_queues(queues), 0) JSON.parse(job) end
push(queue, data)
click to toggle source
# File lib/octokiq/connection.rb, line 17 def push(queue, data) redis.rpush(build_queue(queue), data.to_json) end
Private Instance Methods
build_queue(queue)
click to toggle source
# File lib/octokiq/connection.rb, line 27 def build_queue(queue) "#{Octokiq.configuration.queue_prefix}:#{queue}" end
build_queues(queues)
click to toggle source
# File lib/octokiq/connection.rb, line 23 def build_queues(queues) queues.map { |q| build_queue(q) } end