class Griffin::Engine::Single
Public Class Methods
create(config)
click to toggle source
# File lib/griffin/engine/single.rb, line 8 def self.create(config) serv = Griffin::Server.new( min_pool_size: config[:min_pool_size], max_pool_size: config[:max_pool_size], min_connection_size: config[:min_connection_size], max_connection_size: config[:max_connection_size], max_receive_message_size: config[:max_receive_message_size], max_send_message_size: config[:max_send_message_size], interceptors: config[:interceptors], ) new(serv, config) end
new(server, config)
click to toggle source
# File lib/griffin/engine/single.rb, line 21 def initialize(server, config) @server = server @config = config @sock = TCPServer.new(@config[:bind], @config[:port]) @sock.setsockopt(Socket::IPPROTO_TCP, Socket::TCP_NODELAY, 1) end
Public Instance Methods
install_handler()
click to toggle source
# File lib/griffin/engine/single.rb, line 40 def install_handler trap('INT') do @server.shutdown end trap('TERM') do @server.shutdown end end
run()
click to toggle source
# File lib/griffin/engine/single.rb, line 28 def run @config[:services].each do |s| @server.handle(s) end install_handler @server.before_run @sock.listen(Socket::SOMAXCONN) @server.run(@sock) end