Class: NetX::HTTPUnix
- Inherits:
-
Net::HTTP
- Object
- Net::HTTP
- NetX::HTTPUnix
- Defined in:
- lib/net_x/http_unix.rb
Constant Summary collapse
- BufferedIO =
::Net::BufferedIO
- UNIX_REGEXP =
%r{^unix://}i
Instance Method Summary collapse
- #connect ⇒ Object
-
#connect_unix ⇒ Object
connect_unix is an alternative implementation of Net::HTTP#connect specific to the use case of using a Unix Domain Socket.
-
#initialize(address, port = nil) ⇒ HTTPUnix
constructor
A new instance of HTTPUnix.
Constructor Details
#initialize(address, port = nil) ⇒ HTTPUnix
Returns a new instance of HTTPUnix.
7 8 9 10 11 12 13 14 15 16 17 18 19 20 |
# File 'lib/net_x/http_unix.rb', line 7 def initialize(address, port=nil) super(address, port) case address when UNIX_REGEXP @socket_type = 'unix' @socket_path = address.sub(UNIX_REGEXP, '') # Address and port are set to localhost so the HTTP client constructs # a HOST request header nginx will accept. @address = 'localhost' @port = 80 else @socket_type = 'inet' end end |
Instance Method Details
#connect ⇒ Object
22 23 24 25 26 27 28 |
# File 'lib/net_x/http_unix.rb', line 22 def connect if @socket_type == 'unix' connect_unix else super end end |
#connect_unix ⇒ Object
connect_unix is an alternative implementation of Net::HTTP#connect specific to the use case of using a Unix Domain Socket.
33 34 35 36 37 38 39 40 41 42 |
# File 'lib/net_x/http_unix.rb', line 33 def connect_unix D "opening connection to #{@socket_path}..." s = Timeout.timeout(@open_timeout) { UNIXSocket.open(@socket_path) } D "opened" @socket = BufferedIO.new(s) @socket.read_timeout = @read_timeout @socket.continue_timeout = @continue_timeout @socket.debug_output = @debug_output on_connect end |