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