Module: Semian::NetHTTP
- Includes:
- Adapter
- Defined in:
- lib/semian/net_http.rb
Defined Under Namespace
Classes: SemianConfigurationChangedError
Constant Summary
collapse
- ResourceBusyError =
::Net::ResourceBusyError
- CircuitOpenError =
::Net::CircuitOpenError
- DEFAULT_ERRORS =
[
::Timeout::Error, ::SocketError,
::Net::HTTPBadResponse,
::Net::HTTPHeaderSyntaxError,
::Net::ProtocolError,
::EOFError,
::IOError,
::SystemCallError, ].freeze
Class Attribute Summary collapse
Class Method Summary
collapse
Instance Method Summary
collapse
Methods included from Adapter
#clear_semian_resource, #semian_resource
Class Attribute Details
.exceptions ⇒ Object
Returns the value of attribute exceptions.
47
48
49
|
# File 'lib/semian/net_http.rb', line 47
def exceptions
@exceptions
end
|
.semian_configuration ⇒ Object
Returns the value of attribute semian_configuration.
48
49
50
|
# File 'lib/semian/net_http.rb', line 48
def semian_configuration
@semian_configuration
end
|
Class Method Details
.reset_exceptions ⇒ Object
.retrieve_semian_configuration(host, port) ⇒ Object
55
56
57
|
# File 'lib/semian/net_http.rb', line 55
def retrieve_semian_configuration(host, port)
@semian_configuration.call(host, port) if @semian_configuration.respond_to?(:call)
end
|
Instance Method Details
#connect ⇒ Object
81
82
83
84
|
# File 'lib/semian/net_http.rb', line 81
def connect
return super if disabled?
acquire_semian_resource(adapter: :http, scope: :connection) { super }
end
|
#disabled? ⇒ Boolean
77
78
79
|
# File 'lib/semian/net_http.rb', line 77
def disabled?
raw_semian_options.nil?
end
|
#raw_semian_options ⇒ Object
66
67
68
69
70
71
|
# File 'lib/semian/net_http.rb', line 66
def raw_semian_options
@raw_semian_options ||= begin
@raw_semian_options = Semian::NetHTTP.retrieve_semian_configuration(address, port)
@raw_semian_options = @raw_semian_options.dup unless @raw_semian_options.nil?
end
end
|
#resource_exceptions ⇒ Object
#semian_identifier ⇒ Object
31
32
33
|
# File 'lib/semian/net_http.rb', line 31
def semian_identifier
"nethttp_#{raw_semian_options[:name]}"
end
|
#transport_request ⇒ Object
86
87
88
89
90
91
|
# File 'lib/semian/net_http.rb', line 86
def transport_request(*)
return super if disabled?
acquire_semian_resource(adapter: :http, scope: :query) do
handle_error_responses(super)
end
end
|
#with_resource_timeout(timeout) ⇒ Object
93
94
95
96
97
98
99
100
101
102
103
104
|
# File 'lib/semian/net_http.rb', line 93
def with_resource_timeout(timeout)
prev_read_timeout = read_timeout
prev_open_timeout = open_timeout
begin
self.read_timeout = timeout
self.open_timeout = timeout
yield
ensure
self.read_timeout = prev_read_timeout
self.open_timeout = prev_open_timeout
end
end
|