Class: Scribe::Processor

Inherits:
FacebookService::Processor show all
Includes:
Thrift::Processor
Defined in:
lib/fluent/plugin/thrift/scribe.rb

Instance Method Summary collapse

Methods inherited from FacebookService::Processor

#process_aliveSince, #process_getCounter, #process_getCounters, #process_getCpuProfile, #process_getName, #process_getOption, #process_getOptions, #process_getStatus, #process_getStatusDetails, #process_getVersion, #process_reinitialize, #process_setOption, #process_shutdown

Instance Method Details

#process_Log(seqid, iprot, oprot) ⇒ Object 



35
36
37
38
39
40
 
# File 'lib/fluent/plugin/thrift/scribe.rb', line 35

def process_Log(seqid, iprot, oprot)
  args = read_args(iprot, Log_args)
  result = Log_result.new()
  result.success = @handler.Log(args.messages)
  write_result(result, oprot, 'Log', seqid)
end