-
Notifications
You must be signed in to change notification settings - Fork 231
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
feat: ruby-kafka instrumentation #476
feat: ruby-kafka instrumentation #476
Conversation
092fb97
to
09c98d0
Compare
27b8614
to
32337c8
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.
Moving this out of draft to get some reviews in, I don't feel that this is 100% yet but I think having a review will speed things up a bit.
Review ready.
instrumentation/ruby_kafka/opentelemetry-instrumentation-ruby_kafka.gemspec
Outdated
Show resolved
Hide resolved
...ntation/ruby_kafka/lib/opentelemetry/instrumentation/ruby_kafka/events/connection/request.rb
Outdated
Show resolved
Hide resolved
...n/ruby_kafka/lib/opentelemetry/instrumentation/ruby_kafka/events/consumer/process_message.rb
Outdated
Show resolved
Hide resolved
...ion/ruby_kafka/lib/opentelemetry/instrumentation/ruby_kafka/events/consumer/process_batch.rb
Outdated
Show resolved
Hide resolved
instrumentation/ruby_kafka/lib/opentelemetry/instrumentation/ruby_kafka/patches/client.rb
Show resolved
Hide resolved
32337c8
to
c524bf9
Compare
6be5309
to
8a1ef1b
Compare
Updated to use links in this commit 8a1ef1b |
...umentation/ruby_kafka/test/opentelemetry/instrumentation/ruby-kafka/patches/consumer_test.rb
Outdated
Show resolved
Hide resolved
...umentation/ruby_kafka/test/opentelemetry/instrumentation/ruby-kafka/patches/consumer_test.rb
Outdated
Show resolved
Hide resolved
@counter = 0 | ||
consumer.each_message do |_msg| | ||
@counter += 1 | ||
raise 'oops' if @counter >= 2 |
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.
Oh, I guess it is just to terminate the each_message
loop. Does it need to be a member variable? Wouldn't a local be sufficient?
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.
A local is sufficient, I think there was a reason why it was this way before but it's no longer valid. Updated!
Co-authored-by: Francis Bogsanyi <francis.bogsanyi@shopify.com>
instrumentation/ruby_kafka/lib/opentelemetry/instrumentation/ruby_kafka/patches/consumer.rb
Outdated
Show resolved
Hide resolved
instrumentation/ruby_kafka/lib/opentelemetry/instrumentation/ruby_kafka/patches/consumer.rb
Outdated
Show resolved
Hide resolved
instrumentation/ruby_kafka/lib/opentelemetry/instrumentation/ruby_kafka/patches/consumer.rb
Outdated
Show resolved
Hide resolved
Co-authored-by: Francis Bogsanyi <francis.bogsanyi@shopify.com>
Co-authored-by: Francis Bogsanyi <francis.bogsanyi@shopify.com>
...umentation/ruby_kafka/test/opentelemetry/instrumentation/ruby-kafka/patches/consumer_test.rb
Outdated
Show resolved
Hide resolved
…ruby-kafka/patches/consumer_test.rb Co-authored-by: Francis Bogsanyi <francis.bogsanyi@shopify.com>
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, other than appeasing Rubocop.
Thanks @robertlaurin! I know it was challenging to get this over the finish line.
Todo: