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