-
Notifications
You must be signed in to change notification settings - Fork 645
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
Couchbase: Akka Discovery support #1746
Conversation
couchbase/src/main/scala/akka/stream/alpakka/couchbase/model.scala
Outdated
Show resolved
Hide resolved
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. It is nice how we were able to get away with refactoring settings resolution to async. We will not get lukcy like that with other connectors. :)
Needs a rebase. |
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.
Nice! I like the nodes
function as part of the settings object. :-)
couchbase/src/main/java/akka/stream/alpakka/couchbase/javadsl/DiscoverySupport.java
Show resolved
Hide resolved
couchbase/src/main/scala/akka/stream/alpakka/couchbase/scaladsl/DiscoverySupport.scala
Show resolved
Hide resolved
752937c
to
a4e01ad
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
Purpose
Add support for use of Akka Discovery to configure Couchbase nodes.
Changes
enrichAsync
toCouchbaseSessionSettings
enrichAsync
before using settingsDiscoverySupport
usage