class Fluent::ForwardOutput

def connect(node)

def connect(node)
  # TODO unix socket?
  TCPSocket.new(node.host, node.port)
end