Module: DTR::Service::Agent

Includes:
Rinda
Included in:
Agent::Herald, Monitor::MasterMonitor
Defined in:
lib/dtr/shared/service/agent.rb

Instance Method Summary collapse

Methods included from Rinda

#lookup, #lookup_ring, #start_service, #stop_service

Instance Method Details

#all_agents_info ⇒ Object 



32
33
34
 
# File 'lib/dtr/shared/service/agent.rb', line 32

def all_agents_info
  lookup_ring.read_all([:agent, nil]).collect{|t|t[1]}
end

#new_agent_monitor ⇒ Object 



19
20
21
 
# File 'lib/dtr/shared/service/agent.rb', line 19

def new_agent_monitor
  lookup_ring.notify(nil, [:agent, nil])
end

#provide_agent_info(setup_env_cmd, runners) ⇒ Object 



23
24
25
26
27
28
29
30
 
# File 'lib/dtr/shared/service/agent.rb', line 23

def provide_agent_info(setup_env_cmd, runners)
  agent = %{
- agent(host at #{Socket.gethostname}):
    default setup environment command: '#{setup_env_cmd}'
    runners: #{runners.inspect}
}
  lookup_ring.write [:agent, agent]
end