class Qs::Config

Constants

DEFAULT_DECODER
DEFAULT_DISPATCHER_JOB_HANDLER_CLASS_NAME
DEFAULT_DISPATCHER_JOB_NAME
DEFAULT_DISPATCHER_QUEUE_CLASS
DEFAULT_DISPATCHER_QUEUE_NAME
DEFAULT_ENCODER
DEFAULT_REDIS_DB
DEFAULT_REDIS_DRIVER
DEFAULT_REDIS_IP
DEFAULT_REDIS_NS
DEFAULT_REDIS_PORT
DEFAULT_REDIS_SIZE
DEFAULT_REDIS_TIMEOUT

Attributes

decoder[RW]
dispatcher_job_handler_class_name[RW]
dispatcher_job_name[RW]
dispatcher_queue_class[RW]
dispatcher_queue_name[RW]
encoder[RW]
event_publisher[RW]
redis_db[RW]
redis_driver[RW]
redis_ip[RW]
redis_ns[RW]
redis_port[RW]
redis_size[RW]
redis_timeout[RW]
redis_url[RW]
timeout[RW]

Public Class Methods

new() click to toggle source
# File lib/qs.rb, line 131
def initialize
  @encoder         = DEFAULT_ENCODER
  @decoder         = DEFAULT_DECODER
  @timeout         = nil
  @event_publisher = nil

  @dispatcher_queue_class            = DEFAULT_DISPATCHER_QUEUE_CLASS
  @dispatcher_queue_name             = DEFAULT_DISPATCHER_QUEUE_NAME
  @dispatcher_job_name               = DEFAULT_DISPATCHER_JOB_NAME
  @dispatcher_job_handler_class_name = DEFAULT_DISPATCHER_JOB_HANDLER_CLASS_NAME

  @redis_ip      = DEFAULT_REDIS_IP
  @redis_port    = DEFAULT_REDIS_PORT
  @redis_db      = DEFAULT_REDIS_DB
  @redis_ns      = DEFAULT_REDIS_NS
  @redis_driver  = DEFAULT_REDIS_DRIVER
  @redis_timeout = DEFAULT_REDIS_TIMEOUT
  @redis_size    = DEFAULT_REDIS_SIZE
  @redis_url     = nil

  @valid = nil
end

Public Instance Methods

redis_connect_hash() click to toggle source

the keys here should be compatible with HellaRedis connection configs github.com/redding/hella-redis#usage

# File lib/qs.rb, line 156
def redis_connect_hash
  { :ip       => self.redis_ip,
    :port     => self.redis_port,
    :db       => self.redis_db,
    :redis_ns => self.redis_ns,
    :driver   => self.redis_driver,
    :timeout  => self.redis_timeout,
    :size     => self.redis_size,
    :url      => self.redis_url
  }
end
valid?() click to toggle source
# File lib/qs.rb, line 168
def valid?
  !!@valid
end
validate!() click to toggle source
# File lib/qs.rb, line 172
def validate!
  return @valid if !@valid.nil? # only need to run this once per config

  # set the `redis_url`
  self.redis_url ||= RedisUrl.new(self.redis_ip, self.redis_port, self.redis_db)

  @valid = true
end