fluent.logger_lua

caller.lua

local logger = require 'fluent.logger'
logger.connect()
logger.post('test.test', {message='data'})

logger.lua

local os = require 'os'
local msgpack = require 'msgpack'
local socket = require 'socket'
module('fluent.logger')

local fluent = nil

function connect(host, port)
  fluent = socket.connect(host or '127.0.0.1', port or 24224) 
end

function post(tag, data)
  local p = msgpack.Packer()
  local msg = p:pack({tag, os.time(), data})
  
  fluent:send(msg)
end

function close() 
  fluent:close()
end