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