Skip to content

Instantly share code, notes, and snippets.

View frsyuki's full-sized avatar

Sadayuki Furuhashi frsyuki

View GitHub Profile
module Fluent
class MongoOutput < Fluent::BufferedOutput
Fluent::Plugin.register_output('mongo', self)
def initialize
super
require 'mongo'
require 'msgpack'
a = /\Aforward(?![^\.]).*\Z/
b = /\Aforward[^\.].*\Z/
n = 1000000
require 'benchmark'
Benchmark.bm {|x|
x.report("a") do
n.times do
a =~ "forward.test"
end
<match ...>
type metrics
key ...
tag metrics.mongo
</match>

fluentd-0.10 に対応する方法

Rakefile の修正

パッケージ名が変わりました。add_dependencyを変更して下さい:

gemspec.add_dependency "fluent", "~> 0.9.20"
↓

gemspec.add_dependency "fluentd", "~> 0.10.0"

diff --git a/src/main/java/org/msgpack/MessagePack.java b/src/main/java/org/msgpack/MessagePack.java
index cb047b5..fd8427c 100644
--- a/src/main/java/org/msgpack/MessagePack.java
+++ b/src/main/java/org/msgpack/MessagePack.java
@@ -186,17 +186,15 @@ public class MessagePack {
* @throws IOException
*/
public <T> byte[] write(T v) throws IOException {
- BufferPacker pk = createBufferPacker();
- if (v == null) {
require 'msgpack'
class MessagePackedString < String
def to_msgpack(out = '')
out << self
end
end
def log(tag, record)
r = {}
<match xxx.*>
type in_exec
command cat
in_keys host,message
out_keys host,message
tag filtered.out
</match>
diff --git a/lib/fluent/test/base.rb b/lib/fluent/test/base.rb
index 86b7baa..aa223f1 100644
--- a/lib/fluent/test/base.rb
+++ b/lib/fluent/test/base.rb
@@ -25,7 +25,8 @@ class TestDriver
def initialize(klass, &block)
if klass.is_a?(Class)
if block
- klass = Class.new(klass, &block)
+ klass = klass.dup
@frsyuki
frsyuki / build.sh
Created October 31, 2011 06:45
Build libhadoop.dylib on Mac OS X Lion
patch -p0 <<EOF
diff -ru a/src/native/src/org/apache/hadoop/security/JniBasedUnixGroupsNetgroupMapping.c b/src/native/src/org/apache/hadoop/security/JniBasedUnixGroupsNetgroupMapping.c
--- src/native/src/org/apache/hadoop/security/JniBasedUnixGroupsNetgroupMapping.c 2011-07-19 04:12:32.000000000 +0900
+++ src/native/src/org/apache/hadoop/security/JniBasedUnixGroupsNetgroupMapping.c 2011-10-31 15:27:23.000000000 +0900
@@ -73,7 +73,8 @@
// was successfull or not (as long as it was called we need to call
// endnetgrent)
setnetgrentCalledFlag = 1;
- if(setnetgrent(cgroup) == 1) {
+ setnetgrent(cgroup);
@frsyuki
frsyuki / .bashrc
Created November 4, 2011 07:21
individual bash history file for each `basename path` + screen window
if [ -n "$PROJECT" ];then
if [ -n "$WINDOW" ];then
export HISTFILE="$HOME/.bash_history.d/$PROJECT.$WINDOW"
else
export HISTFILE="$HOME/.bash_history.d/$PROJECT"
fi
if [ ! -f "$HISTFILE" ];then
cp "$HOME/.bash_history" "$HISTFILE"
fi
fi