Module: EtcdTools::Etcd

Included in:
Cli::Etcd2Yaml, Cli::EtcdERB, Cli::Yaml2Etcd, Erb
Defined in:
lib/etcd-tools/etcd.rb

Instance Method Summary collapse

Instance Method Details

#etcd2hash(etcd, path = '') ⇒ Object 



31
32
33
34
35
36
37
38
39
40
41
42
43
 
# File 'lib/etcd-tools/etcd.rb', line 31

def etcd2hash(etcd, path = '')
  h = {}
  etcd.get(path).children.each do |child|
    if etcd.get(child.key).directory?
      h[child.key.split('/').last.to_s] = etcd2hash etcd, child.key
    else
      h[child.key.split('/').last.to_s] = child.value
    end
  end
  return Hash[h.sort]
rescue Exception => e
  return nil
end

#etcd_connect(url) ⇒ Object 



6
7
8
9
10
11
12
13
14
15
 
# File 'lib/etcd-tools/etcd.rb', line 6

def etcd_connect(url)
  (host, port) = url.gsub(/^https?:\/\//, '').gsub(/\/$/, '').split(':')
  etcd = ::Etcd.client(host: host, port: port)
  begin
    etcd.version
    return etcd
  rescue Exception => e
    raise e #fixme
  end
end

#hash2etcd(etcd, hash, path = '') ⇒ Object 



17
18
19
20
21
22
23
24
25
26
27
28
29
 
# File 'lib/etcd-tools/etcd.rb', line 17

def hash2etcd(etcd, hash, path = '')
  hash.each do |key, value|
    path = "" if path == '/'
    etcd_key = path + '/' + key.to_s
    if value.class == Hash
      hash2etcd(etcd, value, etcd_key)
    else
      etcd.set(etcd_key, value: value)
    end
  end
rescue Exception => e
  raise e #fixme
end