Class: ThriftFlumeEventServer::Processor

Inherits:
Object
  • Object
show all
Includes:
Thrift::Processor
Defined in:
lib/fluent/plugin/thrift/thrift_flume_event_server.rb

Instance Method Summary collapse

Instance Method Details

#process_ackedAppend(seqid, iprot, oprot) ⇒ Object 



74
75
76
77
78
79
 
# File 'lib/fluent/plugin/thrift/thrift_flume_event_server.rb', line 74

def process_ackedAppend(seqid, iprot, oprot)
  args = read_args(iprot, AckedAppend_args)
  result = AckedAppend_result.new()
  result.success = @handler.ackedAppend(args.evt)
  write_result(result, oprot, 'ackedAppend', seqid)
end

#process_append(seqid, iprot, oprot) ⇒ Object 



62
63
64
65
66
 
# File 'lib/fluent/plugin/thrift/thrift_flume_event_server.rb', line 62

def process_append(seqid, iprot, oprot)
  args = read_args(iprot, Append_args)
  @handler.append(args.evt)
  return
end

#process_close(seqid, iprot, oprot) ⇒ Object 



81
82
83
84
85
86
 
# File 'lib/fluent/plugin/thrift/thrift_flume_event_server.rb', line 81

def process_close(seqid, iprot, oprot)
  args = read_args(iprot, Close_args)
  result = Close_result.new()
  @handler.close()
  write_result(result, oprot, 'close', seqid)
end

#process_rawAppend(seqid, iprot, oprot) ⇒ Object 



68
69
70
71
72
 
# File 'lib/fluent/plugin/thrift/thrift_flume_event_server.rb', line 68

def process_rawAppend(seqid, iprot, oprot)
  args = read_args(iprot, RawAppend_args)
  @handler.rawAppend(args.evt)
  return
end