@@ -32,7 +32,7 @@ def server_request
32
32
@@server_request
33
33
end
34
34
35
- def set_server_response_code ( code )
35
+ def server_response_code ( code )
36
36
@@server_response_code = code
37
37
end
38
38
@@ -141,7 +141,7 @@ def test_send_compressed_message
141
141
end
142
142
143
143
def test_unrecoverable_error
144
- set_server_response_code ( 500 )
144
+ server_response_code ( 500 )
145
145
event = { "type" => "otlp_logs" , "message" => TestData ::JSON ::LOGS }
146
146
147
147
d = create_driver
@@ -156,15 +156,15 @@ def test_unrecoverable_error
156
156
end
157
157
158
158
def test_error_with_disabled_unrecoverable
159
- set_server_response_code ( 500 )
159
+ server_response_code ( 500 )
160
160
event = { "type" => "otlp_logs" , "message" => TestData ::JSON ::LOGS }
161
161
162
- d = create_driver ( <<~CONFIG )
162
+ d = create_driver ( %[
163
163
<http>
164
164
endpoint "http://127.0.0.1:4318"
165
165
error_response_as_unrecoverable false
166
166
</http>
167
- CONFIG
167
+ ] )
168
168
d . run ( default_tag : "otlp.test" , shutdown : false ) do
169
169
d . feed ( event )
170
170
end
@@ -179,23 +179,23 @@ def test_write_with_retryable_response
179
179
old_report_on_exception = Thread . report_on_exception
180
180
Thread . report_on_exception = false # thread finished as invalid state since RetryableResponse raises.
181
181
182
- set_server_response_code ( 503 )
182
+ server_response_code ( 503 )
183
183
event = { "type" => "otlp_logs" , "message" => TestData ::JSON ::LOGS }
184
184
185
- d = create_driver ( <<~CONFIG )
185
+ d = create_driver ( %[
186
186
<http>
187
187
endpoint "http://127.0.0.1:4318"
188
188
retryable_response_codes [503]
189
189
</http>
190
- CONFIG
190
+ ] )
191
191
192
192
assert_raise ( Fluent ::Plugin ::OtlpOutput ::RetryableResponse ) do
193
193
d . run ( default_tag : "otlp.test" , shutdown : false ) do
194
194
d . feed ( event )
195
195
end
196
196
end
197
197
198
- d . instance_shutdown ( log : $log )
198
+ d . instance_shutdown
199
199
ensure
200
200
Thread . report_on_exception = old_report_on_exception
201
201
end
0 commit comments