Configurable AWS endpoint

x-pack/functionbeat/_meta/beat.reference.yml

@@ -11,6 +11,8 @@
 # Configure functions to run on AWS Lambda, currently we assume that the credentials
 # are present in the environment to correctly create the function when using the CLI.
 #
+# Configure which S3 endpoint should we use.
+functionbeat.provider.aws.endpoint: "s3.amazonaws.com"
 # Configure which S3 bucket we should upload the lambda artifact.
 functionbeat.provider.aws.deploy_bucket: "functionbeat-deploy"
 

x-pack/functionbeat/_meta/beat.yml

@@ -12,6 +12,8 @@
 # Configure functions to run on AWS Lambda, currently we assume that the credentials
 # are present in the environment to correctly create the function when using the CLI.
 #
+# Configure which S3 endpoint should we use.
+functionbeat.provider.aws.endpoint: "s3.amazonaws.com"
 # Configure which S3 bucket we should upload the lambda artifact.
 functionbeat.provider.aws.deploy_bucket: "functionbeat-deploy"
 

x-pack/functionbeat/docs/config-options.asciidoc

@@ -22,6 +22,7 @@ the events to {es}.
 
 ["source","sh",subs="attributes"]
 ----
+{beatname_lc}.provider.aws.endpoint: "s3.amazonaws.com"
 {beatname_lc}.provider.aws.deploy_bucket: "functionbeat-deploy"
 {beatname_lc}.provider.aws.functions:
   - name: cloudwatch
@@ -56,6 +57,12 @@ to deploy.
 TIP: If you change the configuration after deploying the function, use
 the <<update-command,`update` command>> to update your deployment.
 
+[float]
+[id="{beatname_lc}-endpoint"]
+==== `provider.aws.endpoint`
+
+AWS endpoint to use in the URL template to load functions.
+
 [float]
 [id="{beatname_lc}-deploy-bucket"]
 ==== `provider.aws.deploy_bucket`

x-pack/functionbeat/docs/getting-started.asciidoc

@@ -97,6 +97,7 @@ events from CloudWatch Logs and forwards the events to {es}.
 
 ["source","sh",subs="attributes"]
 -------------------------------------------------------------------------------------
+{beatname_lc}.provider.aws.endpoint: "s3.amazonaws.com"
 {beatname_lc}.provider.aws.deploy_bucket: "functionbeat-deploy"
 {beatname_lc}.provider.aws.functions:
   - name: cloudwatch

x-pack/functionbeat/functionbeat.reference.yml

@@ -11,6 +11,8 @@
 # Configure functions to run on AWS Lambda, currently we assume that the credentials
 # are present in the environment to correctly create the function when using the CLI.
 #
+# Configure which S3 endpoint should we use.
+functionbeat.provider.aws.endpoint: "s3.amazonaws.com"
 # Configure which S3 bucket we should upload the lambda artifact.
 functionbeat.provider.aws.deploy_bucket: "functionbeat-deploy"
 

x-pack/functionbeat/functionbeat.yml

@@ -12,6 +12,8 @@
 # Configure functions to run on AWS Lambda, currently we assume that the credentials
 # are present in the environment to correctly create the function when using the CLI.
 #
+# Configure which S3 endpoint should we use.
+functionbeat.provider.aws.endpoint: "s3.amazonaws.com"
 # Configure which S3 bucket we should upload the lambda artifact.
 functionbeat.provider.aws.deploy_bucket: "functionbeat-deploy"
 

x-pack/functionbeat/provider/aws/config.go

@@ -17,6 +17,7 @@ import (
 
 // Config expose the configuration option the AWS provider.
 type Config struct {
+	Endpoint     string `config:"endpoint" validate:"nonzero,required"`
 	DeployBucket bucket `config:"deploy_bucket" validate:"nonzero,required"`
 }
 

x-pack/functionbeat/provider/aws/template_builder.go

@@ -37,6 +37,7 @@ type templateData struct {
 type defaultTemplateBuilder struct {
 	provider provider.Provider
 	log      *logp.Logger
+	endpoint string
 	bucket   string
 }
 
@@ -53,6 +54,7 @@ func NewTemplateBuilder(log *logp.Logger, cfg *common.Config, p provider.Provide
 	return &defaultTemplateBuilder{
 		provider: p,
 		log:      log,
+		endpoint: config.Endpoint,
 		bucket:   string(config.DeployBucket),
 	}, nil
 }
@@ -101,7 +103,7 @@ func (d *defaultTemplateBuilder) execute(name string) (templateData, error) {
 
 	templateChecksum := checksum(templateJSON)
 	templateKey := keyPrefix + name + "/" + templateChecksum + "/cloudformation-template-create.json"
-	templateURL := "https://" + d.bucket + "s3.amazonaws.com/" + templateKey
+	templateURL := "https://" + d.bucket + "." + d.endpoint + "/" + templateKey
 
 	return templateData{
 		json:     templateJSON,

x-pack/functionbeat/tests/system/config/functionbeat.yml.j2

@@ -7,6 +7,7 @@ functionbeat.provider.local:
 {% endif %}
 
 {% if cloudwatch %}
+functionbeat.provider.aws.endpoint: {{ cloudwatch.endpoint | default("s3.amazonaws.com") }}
 functionbeat.provider.aws.deploy_bucket: {{ cloudwatch.bucket | default("functionbeat-deploy") }}
 functionbeat.provider.aws.functions:
   - name: {{ cloudwatch.name }}