class Discobolo::Config

Attributes

actor_concurrency[RW]
auth[RW]
client[RW]
fetch_options[RW]
queues[RW]

Public Class Methods

client=(nodes) click to toggle source
# File lib/discobolo/config.rb, line 14
def self.client=(nodes)
  #client = Disque.new("127.0.0.1:7711", auth: "e727d1464a...")
  @client = Client.new(nodes)
end
logger() click to toggle source
# File lib/discobolo/config.rb, line 24
def self.logger
  @logger || Discobolo::Logger.new($stdout)
end
logger=(arg=nil) click to toggle source
# File lib/discobolo/config.rb, line 19
def self.logger=(arg=nil)
  l = arg.nil? ? arg : $stdout
  @logger = Discobolo::Logger.new(l)
end
setup() { |self| ... } click to toggle source
# File lib/discobolo/config.rb, line 10
def self.setup
  yield self
end

Public Instance Methods

actor_concurrency() click to toggle source
# File lib/discobolo/config.rb, line 28
def actor_concurrency
  @actor_concurrency || 5
end
fetch_options() click to toggle source
# File lib/discobolo/config.rb, line 32
def fetch_options
  @fetch_options || {count: 10, timeout: 2000}
end