Sha256: ec7f79434f8aa17048c557d0b8c3b523947d63296471dc520a05c3d9a35f50cc
Contents?: true
Size: 963 Bytes
Versions: 17
Compression:
Stored size: 963 Bytes
Contents
require 'shipitron'
require 'diplomat'
module Shipitron
module ConsulKeys
extend self
def configure_consul_client!
if ENV['CONSUL_HOST'].nil?
raise 'Environment variable CONSUL_HOST required'
end
Diplomat.configure do |config|
config.url = "http://#{ENV['CONSUL_HOST']}:8500"
end
end
def fetch_key(key:)
Logger.debug "Fetching key #{key}"
value = Diplomat::Kv.get(key, {}, :return)
value = nil if value == ''
value
end
def fetch_key!(key:)
fetch_key(key: key).tap do |value|
if value.nil?
raise "Key #{key} not found in consul!"
end
end
end
def set_key(key:, value:)
Logger.debug "Setting key #{key}"
Diplomat::Kv.put(key, value)
end
def set_key!(key:, value:)
set_key(key: key, value: value).tap do |retval|
raise "Unable to set #{key}!" if retval != true
end
end
end
end
Version data entries
17 entries across 17 versions & 1 rubygems