class Fluent::PluginHelper::Server::UDPCallbackSocket

def initialize(sock, peeraddr, **kwargs)
  super("udp", sock, ENABLED_EVENTS, **kwargs)
  @peeraddr = peeraddr
end

def remote_addr
  @peeraddr[3]
end

def remote_host
  @peeraddr[2]
end

def remote_port
  @peeraddr[1]
end

def write(data)
  @sock.send(data, 0, @peeraddr[3], @peeraddr[1])
end