class Fluent::PluginHelper::Server::TCPCallbackSocket

Constants

ENABLED_EVENTS

Attributes

buffer[RW]

Public Class Methods

new(sock) click to toggle source
# File lib/fluent/plugin_helper/server.rb, line 446
def initialize(sock)
  super("tcp", sock, ENABLED_EVENTS)
  @peeraddr = (@sock.peeraddr rescue PEERADDR_FAILED)
  @buffer = ''
end

Public Instance Methods

write(data) click to toggle source
# File lib/fluent/plugin_helper/server.rb, line 452
def write(data)
  @sock.write(data)
end