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