class Fluent::Plugin::ForwardOutput::Node::SocketCache

def initialize(timeout, log)
  @log = log
  @timeout = timeout
  @active_socks = {}
  @inactive_socks = {}
  @mutex = Mutex.new
end