View jexec.rb
#!/usr/bin/env ruby
require './logstash-core/build/libs/logstash-core-6.0.0-beta1.jar'
ITERATIONS = 50_000_000
class InterfaceTest
include java.lang.Runnable
def initialize
@i = 1
end
View gist:aec2ad986eceb0af9196be59e80c9b24
* Batch block
* Exceptions on add_tag
View mini_filter.rb
define_filter :keymapper do
process do |event|
keys = event.get('[keys]')
vals = event.get('[vals]')
next unless keys && vals && !keys.empty? && !vals.empty?
keys.each.with_index do |key,i|
event.set(key, vals[i])
end
View nginx_forward_proxy.conf
worker_processes 1;
events {
worker_connections 1024;
}
http {
#include mime.types;
default_type application/octet-stream;
View healthy-logstash
2016-11-01 16:46:14
Full thread dump Java HotSpot(TM) 64-Bit Server VM (25.51-b03 mixed mode):
"pool-4-thread-18" #65 prio=5 os_prio=31 tid=0x00007fd5f58bd800 nid=0xbf03 waiting on condition [0x0000700016b07000]
java.lang.Thread.State: WAITING (parking)
at sun.misc.Unsafe.park(Native Method)
- parking to wait for <0x0000000784a48240> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
at java.util.concurrent.locks.LockSupport.park(LockSupport.java:175)
at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039)
View Gemfile
# This is a Logstash generated Gemfile.
# If you modify this file manually all comments and formatting will be lost.
source "https://rubygems.org"
gem "logstash-core", "2.4.0"
gem "logstash-core-event", "2.4.0"
gem "logstash-core-plugin-api", "1.60.4"
gem "file-dependencies", "0.1.6"
gem "ci_reporter_rspec", "1.0.0", :group => :development
gem "simplecov", :group => :development
View logstash-character-hack.conf
input { generator {} }
filter {
ruby {
# Add a \t (tab) by using its ASCII code (9)
code => 'event.set("message", 9.chr + event.get("message"))'
}
ruby {
# Make a new field with the tab removed
code => 'event.set("tabless", event.get("message").gsub(9.chr, ""))'
View example.sh
./logstash_benchmarker.rb --warmup 60 --duration 120 -e "input { generator {} } output { elasticsearch {} }"
View keybase.md

Keybase proof

I hereby claim:

  • I am andrewvc on github.
  • I am andrewvc (https://keybase.io/andrewvc) on keybase.
  • I have a public key whose fingerprint is D111 4B56 078A A1FF A5FD 7DE3 46AC D7C3 2B45 0C77

To claim this, I am signing this object:

View simplekv.conf
input {
generator {
message => "baz=bot blah=bar"
count => 10000000
}
}
filter {
kv {}
mutate {