class ThriftSourceProtocol::Processor

Public Instance Methods

process_append(seqid, iprot, oprot) click to toggle source
# File lib/flume-logger/flume-ng/thrift_source_protocol.rb, line 49
def process_append(seqid, iprot, oprot)
  args = read_args(iprot, Append_args)
  result = Append_result.new()
  result.success = @handler.append(args.event)
  write_result(result, oprot, 'append', seqid)
end
process_appendBatch(seqid, iprot, oprot) click to toggle source
# File lib/flume-logger/flume-ng/thrift_source_protocol.rb, line 56
def process_appendBatch(seqid, iprot, oprot)
  args = read_args(iprot, AppendBatch_args)
  result = AppendBatch_result.new()
  result.success = @handler.appendBatch(args.events)
  write_result(result, oprot, 'appendBatch', seqid)
end