We're currently working on getting our Beam app working with localstack (and potentially other AWS regions). We're using SqsIO and S3 as part of our pipeline (with other AWS components likely to come into the mix). While I could cast the PipelineOptions to AwsOptions and then call AwsOptions.setAwsServiceEndpoint() prior to pipeline construction, that won't work as different AWS services make use of different endpoints -- e.g. the endpoint for SqsIO isn't going to work for S3.
What I'd really like to do is provide a different set of AwsOptions per AWS service. What's the best means of accomplishing this? Tim.
