-
Notifications
You must be signed in to change notification settings - Fork 644
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Refactor S3 API to static factory methods #1395
Conversation
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Looks great!
- Do a KazeClass with
S3Settings
- Why are there different models in
javadsl
andscaladsl
? They seem to be the same. Check if they may use theWriteMessage
/WriteResult
naming standard. - In
HttpRequests
: the settings could be passed explicitly
I'll need another look.
s3/src/main/scala/akka/stream/alpakka/s3/impl/MaterializerAccess.scala
Outdated
Show resolved
Hide resolved
s3/src/main/scala/akka/stream/alpakka/s3/impl/MaterializerAccess.scala
Outdated
Show resolved
Hide resolved
s3/src/main/scala/akka/stream/alpakka/s3/impl/HttpRequests.scala
Outdated
Show resolved
Hide resolved
Addresses PR feedback. Also updated the way Materializer and Attributes are exposed. Instead of using Materialized value is still wrapped into a Still needs a docs rewrite. |
377ff4b
to
33f67fc
Compare
Docs have been refactored. The IBM Bluemix section has been moved to a separate page. Also added a new paragraph and code snipped about using S3Atributes. |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
I really like the outcome from all the work you put into this.
LGTM.
Fixes #1086 |
Fixes #938 |
92e5e42
to
dbe9f50
Compare
Addressed feedback and rebased on top of the current master. |
This is a second attempt to clean up S3 connector API. Instead of creating instances of
S3Client
that then are used to createSource/Flow/Sink
s, all of the factories are moved to theS3
object. If connector implementation needs an ActorSystem, ExecutionContext or S3Settings, all of those are taken from the materializer.Access to the materialized is factored out to
MaterializerAccess
.This PR also enables
MinioS3IntegrationSpec
and configuresminio
docker image for that test.Continuation of #1323
Two test cases are failing. Therefore this is still WIP. One testcase
succeed uploading an empty file
is tricky to fix with the current implementation ofMaterializerAccess.source
, as empty file (empty source) does not work as other sources withSource.lazily
.