-
Notifications
You must be signed in to change notification settings - Fork 647
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
Elasticsearch: towards 1.0 #1179
Conversation
@ennru Based on your comments, I think this looks good |
* Moved implementation to `impl` * Un-case-classed settings * Renamed `ElasticsearchSinkSettings` to `ElasticSearchWriteSettings` API CHANGES
0b39f75
to
4551937
Compare
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.
LGTM. Just a couple of nitpicks.
def getId: String = id | ||
|
||
/** Java API */ | ||
def getSource: T = source |
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.
Unnecessary getter for Java since the types are java-friendly.
val success: Boolean = error.isEmpty | ||
|
||
/** Java API */ | ||
def getMessage: WriteMessage[T2, C2] = message |
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.
Unnecessary java getter.
2cfc570
to
e8166a9
Compare
Major API changes
IncomingMessage
WriteMessage
(non case class)IncomingIndexMessage
WriteMessage.createIndexMessage
IncomingUpdateMessage
WriteMessage.createUpdateMessage
IncomingUpsertMessage
WriteMessage.createUpsertMessage
IncomingDeleteMessage
WriteMessage.createDeleteMessage
IncomingMessageResult
WriteResult
OutgoingMessage
ReadResult
ElasticsearchSinkSettings
is now calledElasticsearchWriteSettings
and no case class anymore. The fields to specify retrying are replaced byRetryLogic
with the two implementationsRetryNever
(default) andRetryAtFixedRate
.ElasticsearchSourceSettings
is no case class anymore.To support implementing stream elements created by the Elasticsearch stages,
akka.stream.alpakka.elasticsearch.testkit.MessageFactory
offers factory methods.Fixes #1070