fix(s3exporter/config-validation): endpoint should contain region and S3 bucket

exporter/awss3exporter/README.md

@@ -30,7 +30,7 @@ The following exporter configuration parameters are supported.
 | `marshaler`           | marshaler used to produce output data                                                                                                      | `otlp_json` |
 | `encoding`            | Encoding extension to use to marshal data. Overrides the `marshaler` configuration option if set.                                          |             |
 | `encoding_file_extension` | file format extension suffix when using the `encoding` configuration option. May be left empty for no suffix to be appended.               |             |
-| `endpoint`            | overrides the endpoint used by the exporter instead of constructing it from `region` and `s3_bucket`                                       |             |
+| `endpoint`            | (REST API endpoint) overrides the endpoint used by the exporter instead of constructing it from `region` and `s3_bucket`                                       |             |
 | `s3_force_path_style` | [set this to `true` to force the request to use path-style addressing](http://docs.aws.amazon.com/AmazonS3/latest/dev/VirtualHosting.html) | false       |
 | `disable_ssl`         | set this to `true` to disable SSL when sending requests                                                                                    | false       |
 | `compression`         | should the file be compressed                                                                                                              | none        |

exporter/awss3exporter/config.go

@@ -50,7 +50,7 @@ func (c *Config) Validate() error {
 	if c.S3Uploader.Region == "" {
 		errs = multierr.Append(errs, errors.New("region is required"))
 	}
-	if c.S3Uploader.S3Bucket == "" {
+	if c.S3Uploader.S3Bucket == "" && c.S3Uploader.Endpoint == "" {
 		errs = multierr.Append(errs, errors.New("bucket is required"))
 	}
 	compression := c.S3Uploader.Compression

exporter/awss3exporter/config_test.go

@@ -109,12 +109,24 @@ func TestConfig_Validate(t *testing.T) {
 		errExpected error
 	}{
 		{
-			name: "valid",
+			// endpoint overrides region and bucket name.
+			name: "valid with endpoint and region",
+			config: func() *Config {
+				c := createDefaultConfig().(*Config)
+				c.S3Uploader.Endpoint = "http://example.com"
+				c.S3Uploader.Region = "foo"
+				return c
+			}(),
+			errExpected: nil,
+		},
+		{
+			// Endpoint will be built from bucket and region.
+			// https://docs.aws.amazon.com/AmazonS3/latest/userguide/VirtualHosting.html
+			name: "valid with S3Bucket and region",
 			config: func() *Config {
 				c := createDefaultConfig().(*Config)
 				c.S3Uploader.Region = "foo"
 				c.S3Uploader.S3Bucket = "bar"
-				c.S3Uploader.Endpoint = "http://example.com"
 				return c
 			}(),
 			errExpected: nil,
@@ -124,32 +136,43 @@ func TestConfig_Validate(t *testing.T) {
 			config: func() *Config {
 				c := createDefaultConfig().(*Config)
 				c.S3Uploader.Region = ""
+				c.S3Uploader.S3Bucket = ""
+				c.S3Uploader.Endpoint = ""
 				return c
 			}(),
 			errExpected: multierr.Append(errors.New("region is required"),
-				errors.New("bucket is required")),
+				errors.New("bucket or endpoint is required")),
 		},
 		{
-			name: "endpoint and region",
+			name: "region only",
 			config: func() *Config {
 				c := createDefaultConfig().(*Config)
-				c.S3Uploader.Endpoint = "http://example.com"
 				c.S3Uploader.Region = "foo"
+				c.S3Uploader.S3Bucket = ""
 				return c
 			}(),
 			errExpected: errors.New("bucket is required"),
 		},
 		{
-			name: "endpoint and bucket",
+			name: "bucket only",
 			config: func() *Config {
 				c := createDefaultConfig().(*Config)
-				c.S3Uploader.Endpoint = "http://example.com"
 				c.S3Uploader.S3Bucket = "foo"
 				c.S3Uploader.Region = ""
 				return c
 			}(),
 			errExpected: errors.New("region is required"),
 		},
+		{
+			name: "endpoint only",
+			config: func() *Config {
+				c := createDefaultConfig().(*Config)
+				c.S3Uploader.Endpoint = "http://example.com"
+				c.S3Uploader.Region = ""
+				return c
+			}(),
+			errExpected: errors.New("region is required"),
+		},
 	}
 
 	for _, tt := range tests {