Class: Rebat::Thrift::RebatDB::Processor

Inherits:
Object
  • Object
show all
Includes:
Thrift::Processor
Defined in:
lib/rebat/thrift/rebat_d_b.rb

Instance Method Summary collapse

Instance Method Details

#process_addQuery(seqid, iprot, oprot) ⇒ Object 



96
97
98
99
100
101
 
# File 'lib/rebat/thrift/rebat_d_b.rb', line 96

def process_addQuery(seqid, iprot, oprot)
  args = read_args(iprot, AddQuery_args)
  result = AddQuery_result.new()
  result.success = @handler.addQuery(args.edge)
  write_result(result, oprot, 'addQuery', seqid)
end

#process_deleteQuery(seqid, iprot, oprot) ⇒ Object 



103
104
105
106
107
108
 
# File 'lib/rebat/thrift/rebat_d_b.rb', line 103

def process_deleteQuery(seqid, iprot, oprot)
  args = read_args(iprot, DeleteQuery_args)
  result = DeleteQuery_result.new()
  result.success = @handler.deleteQuery(args.edge)
  write_result(result, oprot, 'deleteQuery', seqid)
end

#process_selectQuery(seqid, iprot, oprot) ⇒ Object 



117
118
119
120
121
122
 
# File 'lib/rebat/thrift/rebat_d_b.rb', line 117

def process_selectQuery(seqid, iprot, oprot)
  args = read_args(iprot, SelectQuery_args)
  result = SelectQuery_result.new()
  result.success = @handler.selectQuery(args.queryList)
  write_result(result, oprot, 'selectQuery', seqid)
end

#process_truncate(seqid, iprot, oprot) ⇒ Object 



124
125
126
127
128
129
 
# File 'lib/rebat/thrift/rebat_d_b.rb', line 124

def process_truncate(seqid, iprot, oprot)
  args = read_args(iprot, Truncate_args)
  result = Truncate_result.new()
  result.success = @handler.truncate()
  write_result(result, oprot, 'truncate', seqid)
end

#process_updateWeightQuery(seqid, iprot, oprot) ⇒ Object 



110
111
112
113
114
115
 
# File 'lib/rebat/thrift/rebat_d_b.rb', line 110

def process_updateWeightQuery(seqid, iprot, oprot)
  args = read_args(iprot, UpdateWeightQuery_args)
  result = UpdateWeightQuery_result.new()
  result.success = @handler.updateWeightQuery(args.edge, args.weight)
  write_result(result, oprot, 'updateWeightQuery', seqid)
end