-
Notifications
You must be signed in to change notification settings - Fork 24
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
Fix drop events between two logstash instances #7
Conversation
as the LSF's spoolsize
This PR introduce the `bulk` send feature of the ruby client and add a local buffer inside this plugin. Theses changes make the plugin closer to the LSF behavior.
@jsvd Can you test this? you need latest version of elastic/ruby-lumberjack#9 |
"hosts" => [host], | ||
"port" => port, | ||
"ssl_certificate" => certificate_file_crt, | ||
"flush_size" => 10#batch_size # flush at the end of the payload |
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.
10? why not batch_size
?
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 usually test with static variable before adding random values this is left over.
@ph for clarification, this PR requires elastic/ruby-lumberjack#9 be released first, right? |
@jordansissel yes, elastic/ruby-lumberjack#9 add support for bulk send which this PR need |
code review done |
@jordansissel Can I get a LGTM for this one? I'll squash after. |
@ph will review shortly <3 |
Code + Test code looks good, will test shortly. |
Can't build the gem:
|
@@ -24,7 +24,12 @@ Gem::Specification.new do |s| | |||
s.add_runtime_dependency "logstash-core", '>= 1.4.0', '< 2.0.0' | |||
|
|||
s.add_runtime_dependency 'jls-lumberjack', ['>=0.0.23'] | |||
s.add_runtime_dependency "stud" |
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.
Maybe rubygems doesn't allow both runtime and dev dependency with the same lib?
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.
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 have updated the PR.
Successfully built RubyGem
Name: logstash-output-lumberjack
Version: 1.0.1
File: logstash-output-lumberjack-1.0.1.gem
Confirmed tests passing for me |
Tested perf is 2x (eyeballing it with |
Merged sucessfully into master! |
This PR introduce the `bulk` send feature of the ruby client and add a local buffer inside this plugin. Theses changes make the plugin closer to the LSF behavior. Fixes #7
This PR introduce the
bulk
send feature of the ruby client and add alocal buffer inside this plugin. Theses changes make the plugin closer
to the LSF behavior.