libfluent
Fluentd library in C++. The library makes C++ program available to send logs to fluentd daemon directly.
#include <fluent.hpp>
int main(int argc, char *argv[]) {
fluent::Logger *logger = new fluent::Logger();
logger->new_forward("localhost", 24224);
// Emit log:
// tag: "tag.http"
// time: 1422315xxx (auto)
// data: {"url": "http://github.com", "port": 443}
fluent::Message *msg = logger->retain_message("tag.http");
msg->set("url", "http://github.com");
msg->set("port", 443);
logger->emit(msg);
delete logger;
}Functions
- Support nested message such as
{"a": {"b": {"c": 3}}} - Support array in message such as
{"a": [1, 2, 3]} - Asynchronous emitting and buffering
- Reconnect when disconnected
- Exponential backoff for reconnect
Prerequisite
- C++11 compiler
- libmsgpack >= 0.5.9
- ruby, fluentd, msgpack-ruby (for test)
Install
% cmake .
% make
% sudo make installExamples
Nested Array/Map
Map
fluent::Message *msg = logger->retain_message("test.map");
// {}
msg->set("t1", "a");
// {"t1": "a"}
fluent::Message::Map *m1 = msg->retain_map("map1");
// {"t1": "a", "map1": {}}
m1->set("t2", "b");
// {"t2": "a", "map1": {"t2": "b"}}
fluent::Message::Map *m2 = m1->retain_map("map2");
// {"t1": "a", "map1": {"t2": "b", "map2":{}}}
m2->set("t2", "b");
// {"t2": "a", "map1": {"t2": "b", "map2":{"t2": "b"}}}Array
fluent::Message *msg = logger->retain_message("test.array");
// {}
fluent::Message::Array *arr = msg->retain_array("arr1");
// {"arr1": []}
arr->push(1);
// {"arr1": [1]}
arr->push(2);
// {"arr1": [1, 2]}
fluent::Message::Map *map = arr->retain_map("map2");
// {"arr1": [1, 2, {}]}
map->set("t", "a");
// {"arr1": [1, 2, {"t": "a"}]}Author
- Masayoshi Mizutani [email protected]