Class: Odania::Consul::Service

Inherits:
Object
  • Object
show all
Defined in:
lib/odania/consul.rb

Instance Method Summary collapse

Instance Method Details

#build_config(plugin_name, plugin_instance_name, ip, tags = [], port = 80) ⇒ Object 



101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
 
# File 'lib/odania/consul.rb', line 101

def build_config(plugin_name, plugin_instance_name, ip, tags=[], port=80)
  {
    'id' => plugin_instance_name,
    'name' => plugin_name,
    'tags' => tags,
    'address' => ip,
    'port' => port,
    'token' => plugin_instance_name,
    'checks' => [
      {
        'id' => plugin_name,
        'name' => "HTTP on port #{port}",
        'http' => "http://#{ip}:#{port}/health",
        'interval' => '10s',
        'timeout' => '1s'
      }
    ]
  }
end

#deregister(name) ⇒ Object 



97
98
99
 
# File 'lib/odania/consul.rb', line 97

def deregister(name)
  Diplomat::Service.deregister name
end

#get(key, scope = :first) ⇒ Object 



85
86
87
 
# File 'lib/odania/consul.rb', line 85

def get(key, scope=:first)
  Diplomat::Service.get(key, scope)
end

#get_all ⇒ Object 



57
58
59
60
61
62
63
64
 
# File 'lib/odania/consul.rb', line 57

def get_all
  services = {}
  Diplomat::Service.get_all.each_pair do |key, _value|
    services[key.to_s] = get_all_for(key)
  end
  $logger.info "SERVICES: #{JSON.pretty_generate services}" if $debug
  services
end

#get_all_for(plugin_name) ⇒ Object 



66
67
68
69
70
71
72
73
 
# File 'lib/odania/consul.rb', line 66

def get_all_for(plugin_name)
  begin
    instances = get(plugin_name, :all)
  rescue
    instances = []
  end
  instances.is_a?(Array) ? instances : [instances]
end

#get_core_service ⇒ Object

TODO Is there an easier way to get the first service tagges with “core-backend”?



76
77
78
79
80
81
82
83
 
# File 'lib/odania/consul.rb', line 76

def get_core_service
  core_backends = []
  Diplomat::Service.get_all.each_pair do |key, tags|
    core_backends << key if tags.include? 'core-backend'
  end

  get(core_backends.shuffle.first)
end

#register(consul_config) ⇒ Object 



89
90
91
92
93
94
95
 
# File 'lib/odania/consul.rb', line 89

def register(consul_config)
  if Diplomat::Service.register consul_config
    $logger.info 'Service registered' if $debug
  else
    $logger.error 'Error registering service'
  end
end