Exception: Fluent::BigQuery::Error
Abstract
- Inherits:
-
StandardError
- Object
- StandardError
- Fluent::BigQuery::Error
show all
- Defined in:
- lib/fluent/plugin/bigquery/errors.rb
Overview
Constant Summary
collapse
- RETRYABLE_ERROR_REASON =
%w(backendError internalError rateLimitExceeded tableUnavailable).freeze
- RETRYABLE_INSERT_ERRORS_REASON =
%w(timeout backendError internalError rateLimitExceeded).freeze
- RETRYABLE_STATUS_CODE =
[500, 502, 503, 504]
Instance Attribute Summary collapse
Class Method Summary
collapse
Instance Method Summary
collapse
Constructor Details
#initialize(message, origin = nil) ⇒ Error
Returns a new instance of Error.
50
51
52
53
|
# File 'lib/fluent/plugin/bigquery/errors.rb', line 50
def initialize(message, origin = nil)
@origin = origin
super(message || origin.message)
end
|
Dynamic Method Handling
This class handles dynamic methods through the method_missing method
#method_missing(name, *args) ⇒ Object
55
56
57
58
59
60
61
|
# File 'lib/fluent/plugin/bigquery/errors.rb', line 55
def method_missing(name, *args)
if @origin
@origin.send(name, *args)
else
super
end
end
|
Instance Attribute Details
#origin ⇒ Object
Returns the value of attribute origin.
48
49
50
|
# File 'lib/fluent/plugin/bigquery/errors.rb', line 48
def origin
@origin
end
|
Class Method Details
.inherited(subclass) ⇒ Object
39
40
41
42
43
44
45
|
# File 'lib/fluent/plugin/bigquery/errors.rb', line 39
def inherited(subclass)
subclass.class_eval do
class << self
public :new
end
end
end
|
.retryable_error?(google_api_error) ⇒ Boolean
21
22
23
24
25
26
27
|
# File 'lib/fluent/plugin/bigquery/errors.rb', line 21
def retryable_error?(google_api_error)
e = google_api_error
reason = e.respond_to?(:reason) ? e.reason : nil
retryable_error_reason?(reason) ||
(e.is_a?(Google::Apis::ServerError) && RETRYABLE_STATUS_CODE.include?(e.status_code))
end
|
.retryable_error_reason?(reason) ⇒ Boolean
29
30
31
|
# File 'lib/fluent/plugin/bigquery/errors.rb', line 29
def retryable_error_reason?(reason)
RETRYABLE_ERROR_REASON.include?(reason)
end
|
.retryable_insert_errors_reason?(reason) ⇒ Boolean
33
34
35
|
# File 'lib/fluent/plugin/bigquery/errors.rb', line 33
def retryable_insert_errors_reason?(reason)
RETRYABLE_INSERT_ERRORS_REASON.include?(reason)
end
|
.wrap(google_api_error, message = nil, force_unretryable: false) ⇒ Object
10
11
12
13
14
15
16
17
18
19
|
# File 'lib/fluent/plugin/bigquery/errors.rb', line 10
def wrap(google_api_error, message = nil, force_unretryable: false)
e = google_api_error
return UnRetryableError.new(message, e) if force_unretryable
if retryable_error?(e)
RetryableError.new(message, e)
else
UnRetryableError.new(message, e)
end
end
|
Instance Method Details
#body ⇒ Object
71
72
73
|
# File 'lib/fluent/plugin/bigquery/errors.rb', line 71
def body
@origin && @origin.respond_to?(:body) ? @origin.body : nil
end
|
#reason ⇒ Object
63
64
65
|
# File 'lib/fluent/plugin/bigquery/errors.rb', line 63
def reason
@origin && @origin.respond_to?(:reason) ? @origin.reason : nil
end
|
#retryable? ⇒ Boolean
75
76
77
|
# File 'lib/fluent/plugin/bigquery/errors.rb', line 75
def retryable?
false
end
|
#status_code ⇒ Object
67
68
69
|
# File 'lib/fluent/plugin/bigquery/errors.rb', line 67
def status_code
@origin && @origin.respond_to?(:status_code) ? @origin.status_code : nil
end
|