Class: Falcon::Supervisor

Inherits:
Object
  • Object
show all
Defined in:
lib/falcon/supervisor.rb

Defined Under Namespace

Classes: Statistics

Instance Method Summary collapse

Constructor Details

#initialize(endpoint) ⇒ Supervisor

Returns a new instance of Supervisor.



68
69
70
 
# File 'lib/falcon/supervisor.rb', line 68

def initialize(endpoint)
	@endpoint = endpoint
end

Instance Method Details

#handle(message) ⇒ Object 



85
86
87
88
89
90
91
92
 
# File 'lib/falcon/supervisor.rb', line 85

def handle(message)
	case message[:please]
	when 'restart'
		self.restart(message)
	when 'statistics'
		self.statistics(message)
	end
end

#restart(message) ⇒ Object 



72
73
74
75
76
77
 
# File 'lib/falcon/supervisor.rb', line 72

def restart(message)
	signal = message[:signal] || :INT
	
	# Sepukku:
	Process.kill(signal, -Process.getpgrp)
end

#run ⇒ Object 



94
95
96
97
98
99
100
101
102
103
104
 
# File 'lib/falcon/supervisor.rb', line 94

def run
	Async.logger.info("Binding to #{@endpoint}")
	@endpoint.accept do |peer|
		stream = Async::IO::Stream.new(peer)
		
		while message = stream.gets("\0")
			response = handle(JSON.parse(message, symbolize_names: true))
			stream.puts(response.to_json, separator: "\0")
		end
	end
end

#statistics(message) ⇒ Object 



79
80
81
82
83
 
# File 'lib/falcon/supervisor.rb', line 79

def statistics(message)
	statistics = Statistics.new
	
	statistics.capture
end