RFC - Add the DataAdapter pattern to the SQS Stream Provider

[jamescarter-le]

The EventHub StreamProvider has a concept of a DataAdapter, where the user can inject their own implemention to parse messages for the queue, specifically for the purpose of picking up messages from sources that are not Orleans, and have not already passed through the StreamProvider.

I am attempting to implement this in the SQS provider, as I need similar functionality.

Request for comments / code review on this PR, I need to pull some more data out to configuration still.

The first commit was required to get the SQS tests passing, before I moved on to the commit with the Data Adapter change.

Contract changes:

• SQSBatchContainer changed from internal to public (as the DataAdapter needs to construct one, this is crux of the change).
• SQSBatchContainer.ctor changed from internal to public as it is the only method of passing a SequenceToken to the object.

Alternative approach, would be to have the consumer implement an IBatchContainer but it would be nice to have a default one.

Microsoft Reviewers: Open in CodeFlow

[jamescarter-le]

Could a core member check if the SQS tests are actually getting run in CI? If you pull master and run AWSUtils.Tests.Streaming.SQSAdapterTests it will fail before my Fix SQS Tests commit but CI pipeline reports it's all fine.

[jamescarter-le]

Just rebased this ontop of main for Orleans 8.0.0

Would appreciate someone looking to see if we can merge this PR.

[jamescarter-le]

@benjaminpetit Any possibility of getting this change into Orleans 8.1.0?

[jamescarter-le]

Hey Orleans team,

Is there something that is designed wrong in this PR that is preventing us from pulling it into Orleans?

I would really like to get away from having to rebase on each Orleans release and maintaining a fork for our apps.

I'm sure being able to support Native -> Orleans streams via SQS would be useful for others.

Let me know if I need to alter this PR in any way to get it included.