class Fluent::Counter::BaseSocket

Public Instance Methods

on_message(data) click to toggle source
# File lib/fluent/counter/base_socket.rb, line 35
def on_message(data)
  raise NotImplementedError
end
on_read(data) click to toggle source
# File lib/fluent/counter/base_socket.rb, line 29
def on_read(data)
  msgpack_unpacker.feed_each(data) do |d|
    on_message d
  end
end
packed_write(data) click to toggle source
# File lib/fluent/counter/base_socket.rb, line 25
def packed_write(data)
  write pack(data)
end

Private Instance Methods

pack(data) click to toggle source
# File lib/fluent/counter/base_socket.rb, line 41
def pack(data)
  msgpack_packer.pack(data)
end