-
Notifications
You must be signed in to change notification settings - Fork 149
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
Rework PhiAccrualFailureDetector to enable monitoring of interval #1137
Conversation
3329e86
to
018fafd
Compare
018fafd
to
8ccd954
Compare
8ccd954
to
5957aa1
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
remote/src/main/scala/org/apache/pekko/remote/PhiAccrualFailureDetector.scala
Outdated
Show resolved
Hide resolved
Would it be possible to write a fuller description to the issue? This is a non-trivial change to our code and we need to be able to release note it. |
@pjfanning I can add more to the issue. But I’d consider this a rather trivial change. There is no functional difference, the implementation is now open for Kanela to intercept the call to the new method to report that metric to Kamon. Or to extend this class and overwrite the method to get the interval. Also the new trait makes it possible to implement a custom failure detector with the same functionality. |
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, as far as I can tell this is just shuffling code around so certain parts of it can be overridden (i.e. enabling features like monitoring interval).
remote/src/main/scala/org/apache/pekko/remote/PhiAccrualFailureDetector.scala
Show resolved
Hide resolved
5957aa1
to
a549ce5
Compare
Looks like link validator is broken because the url changed from |
This is unrelated to this PR so you can file an issue or fix it in another PR |
remote/src/main/scala/org/apache/pekko/remote/FailureDetector.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.
If the usercase is for aop,then we should better have javadsl in mind too.
The use case would be to intercept or override the call to |
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
4de0f4b
to
48b7a7e
Compare
Had to add a mima exclude for the removed |
This would be ready to merge unless there are some objections/further remarks |
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
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.
Just a minor thing, want to add a NOTE
prefix to comment so that it appears in IDE"s then I will approve
remote/src/main/scala/org/apache/pekko/remote/PhiAccrualFailureDetector.scala
Outdated
Show resolved
Hide resolved
remote/src/main/scala/org/apache/pekko/remote/PhiAccrualFailureDetector.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, just added a commit to capitalize the note
…ache#1137) * Introduce trait to avoid matching concrete subclass * Extract interval method to make it available for recording metrics --------- Co-authored-by: Matthew de Detrich <matthew.dedetrich@aiven.io>
resolves #1136