class ThriftSourceProtocol::Client
Public Instance Methods
append(event)
click to toggle source
# File lib/flume-logger/flume-ng/thrift_source_protocol.rb, line 14 def append(event) send_append(event) return recv_append() end
appendBatch(events)
click to toggle source
# File lib/flume-logger/flume-ng/thrift_source_protocol.rb, line 29 def appendBatch(events) send_appendBatch(events) return recv_appendBatch() end
recv_append()
click to toggle source
# File lib/flume-logger/flume-ng/thrift_source_protocol.rb, line 23 def recv_append() result = receive_message(Append_result) return result.success unless result.success.nil? raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'append failed: unknown result') end
recv_appendBatch()
click to toggle source
# File lib/flume-logger/flume-ng/thrift_source_protocol.rb, line 38 def recv_appendBatch() result = receive_message(AppendBatch_result) return result.success unless result.success.nil? raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'appendBatch failed: unknown result') end
send_append(event)
click to toggle source
# File lib/flume-logger/flume-ng/thrift_source_protocol.rb, line 19 def send_append(event) send_message('append', Append_args, :event => event) end
send_appendBatch(events)
click to toggle source
# File lib/flume-logger/flume-ng/thrift_source_protocol.rb, line 34 def send_appendBatch(events) send_message('appendBatch', AppendBatch_args, :events => events) end