lib/skalera/services/redis.rb in skalera-services-0.2.3 vs lib/skalera/services/redis.rb in skalera-services-0.2.4
- old
+ new
@@ -1,15 +1,18 @@
require 'redis'
module Skalera
module Services
class Redis
+ SERVICE_NAME = 'redis'
def self.instance(database = 0)
- redis_config = Diplomat::Service.get('redis')
+ redis_config = Diplomat::Service.get(SERVICE_NAME)
redis = ::Redis.new(url: url(password, redis_config.Address, redis_config.ServicePort, database))
at_exit { redis.quit }
redis
+ rescue Diplomat::KeyNotFound
+ STDERR.puts "ERROR: service not found: #{SERVICE_NAME}"
end
def self.url(password, host, port, database)
pwd = password ? "#{password}:" : ''
"redis://#{pwd}#{host}:#{port}/#{database}"