Class: Droonga::Client::Connection::DroongaProtocol::Coolio::Sender

Inherits:

Coolio::TCPSocket

Object
Coolio::TCPSocket
Droonga::Client::Connection::DroongaProtocol::Coolio::Sender

Defined in:: lib/droonga/client/connection/droonga-protocol/coolio.rb

Instance Method Summary collapse

#initialize(socket) ⇒ Sender constructor
A new instance of Sender.
#send(tag, data) ⇒ Object

Constructor Details

#initialize(socket) ⇒ `Sender`

Returns a new instance of Sender.



50
51
52

# File 'lib/droonga/client/connection/droonga-protocol/coolio.rb', line 50

def initialize(socket)
  super(socket)
end

Instance Method Details

#send(tag, data) ⇒ `Object`

# File 'lib/droonga/client/connection/droonga-protocol/coolio.rb', line 54

def send(tag, data)
  fluent_message = [tag, Time.now.to_i, data]
  packed_fluent_message = MessagePackPacker.pack(fluent_message)
  write(packed_fluent_message)
end