class Concord::Thrift::ComputationService::Processor
Public Instance Methods
process_boltMetadata(seqid, iprot, oprot)
click to toggle source
# File lib/gen-rb/computation_service.rb, line 144 def process_boltMetadata(seqid, iprot, oprot) args = read_args(iprot, BoltMetadata_args) result = BoltMetadata_result.new() begin result.success = @handler.boltMetadata() rescue ::Concord::Thrift::BoltError => e result.e = e end write_result(result, oprot, 'boltMetadata', seqid) end
process_boltProcessRecords(seqid, iprot, oprot)
click to toggle source
# File lib/gen-rb/computation_service.rb, line 122 def process_boltProcessRecords(seqid, iprot, oprot) args = read_args(iprot, BoltProcessRecords_args) result = BoltProcessRecords_result.new() begin result.success = @handler.boltProcessRecords(args.records) rescue ::Concord::Thrift::BoltError => e result.e = e end write_result(result, oprot, 'boltProcessRecords', seqid) end
process_boltProcessTimer(seqid, iprot, oprot)
click to toggle source
# File lib/gen-rb/computation_service.rb, line 133 def process_boltProcessTimer(seqid, iprot, oprot) args = read_args(iprot, BoltProcessTimer_args) result = BoltProcessTimer_result.new() begin result.success = @handler.boltProcessTimer(args.key, args.time) rescue ::Concord::Thrift::BoltError => e result.e = e end write_result(result, oprot, 'boltProcessTimer', seqid) end
process_destroy(seqid, iprot, oprot)
click to toggle source
# File lib/gen-rb/computation_service.rb, line 111 def process_destroy(seqid, iprot, oprot) args = read_args(iprot, Destroy_args) result = Destroy_result.new() begin @handler.destroy() rescue ::Concord::Thrift::BoltError => e result.e = e end write_result(result, oprot, 'destroy', seqid) end
process_init(seqid, iprot, oprot)
click to toggle source
# File lib/gen-rb/computation_service.rb, line 100 def process_init(seqid, iprot, oprot) args = read_args(iprot, Init_args) result = Init_result.new() begin result.success = @handler.init() rescue ::Concord::Thrift::BoltError => e result.e = e end write_result(result, oprot, 'init', seqid) end