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