File tree Expand file tree Collapse file tree 2 files changed +3
-3
lines changed Expand file tree Collapse file tree 2 files changed +3
-3
lines changed Original file line number Diff line number Diff line change @@ -118,11 +118,11 @@ def initialize
118
118
def configure ( conf )
119
119
super
120
120
121
- if @s3_endpoint && @s3_endpoint . end_with? ( 'amazonaws.com' )
121
+ if @s3_endpoint && ( @s3_endpoint . end_with? ( 'amazonaws.com' ) && ! [ 'fips' , 'gov' ] . any? { | e | @s3_endpoint . include? ( e ) } )
122
122
raise Fluent ::ConfigError , "s3_endpoint parameter is not supported for S3, use s3_region instead. This parameter is for S3 compatible services"
123
123
end
124
124
125
- if @sqs . endpoint && @sqs . endpoint . end_with? ( 'amazonaws.com' )
125
+ if @sqs_endpoint && ( @sqs_endpoint . end_with? ( 'amazonaws.com' ) && ! [ 'fips' , 'gov' ] . any? { | e | @sqs_endpoint . include? ( e ) } )
126
126
raise Fluent ::ConfigError , "sqs/endpoint parameter is not supported for SQS, use s3_region instead. This parameter is for SQS compatible services"
127
127
end
128
128
Original file line number Diff line number Diff line change @@ -175,7 +175,7 @@ def configure(conf)
175
175
176
176
Aws . use_bundled_cert! if @use_bundled_cert
177
177
178
- if @s3_endpoint && @s3_endpoint . end_with? ( 'amazonaws.com' )
178
+ if @s3_endpoint && ( @s3_endpoint . end_with? ( 'amazonaws.com' ) && ! [ 'fips' , 'gov' ] . any? { | e | @s3_endpoint . include? ( e ) } )
179
179
raise Fluent ::ConfigError , "s3_endpoint parameter is not supported for S3, use s3_region instead. This parameter is for S3 compatible services"
180
180
end
181
181
You can’t perform that action at this time.
0 commit comments