Class: Haplocheirus::TimelineStore::Processor

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

Instance Method Summary collapse

Instance Method Details

#process_append(seqid, iprot, oprot) ⇒ Object 



236
237
238
239
240
241
242
243
244
245
 
# File 'lib/haplocheirus/thrift/timeline_store.rb', line 236

def process_append(seqid, iprot, oprot)
  args = read_args(iprot, Append_args)
  result = Append_result.new()
  begin
    @handler.append(args.entry, args.timeline_prefix, args.timeline_ids)
  rescue Haplocheirus::TimelineStoreException => ex
    result.ex = ex
  end
  write_result(result, oprot, 'append', seqid)
end

#process_delete_timeline(seqid, iprot, oprot) ⇒ Object 



371
372
373
374
375
376
377
378
379
380
 
# File 'lib/haplocheirus/thrift/timeline_store.rb', line 371

def process_delete_timeline(seqid, iprot, oprot)
  args = read_args(iprot, Delete_timeline_args)
  result = Delete_timeline_result.new()
  begin
    @handler.delete_timeline(args.timeline_id)
  rescue Haplocheirus::TimelineStoreException => ex
    result.ex = ex
  end
  write_result(result, oprot, 'delete_timeline', seqid)
end

#process_filter(seqid, iprot, oprot) ⇒ Object 



258
259
260
261
262
263
264
265
266
267
 
# File 'lib/haplocheirus/thrift/timeline_store.rb', line 258

def process_filter(seqid, iprot, oprot)
  args = read_args(iprot, Filter_args)
  result = Filter_result.new()
  begin
    result.success = @handler.filter(args.timeline_id, args.entries, args.max_search)
  rescue Haplocheirus::TimelineStoreException => ex
    result.ex = ex
  end
  write_result(result, oprot, 'filter', seqid)
end

#process_filter2(seqid, iprot, oprot) ⇒ Object 



269
270
271
272
273
274
275
276
277
278
 
# File 'lib/haplocheirus/thrift/timeline_store.rb', line 269

def process_filter2(seqid, iprot, oprot)
  args = read_args(iprot, Filter2_args)
  result = Filter2_result.new()
  begin
    result.success = @handler.filter2(args.timeline_id, args.id, args.max_search)
  rescue Haplocheirus::TimelineStoreException => ex
    result.ex = ex
  end
  write_result(result, oprot, 'filter2', seqid)
end

#process_get(seqid, iprot, oprot) ⇒ Object 



280
281
282
283
284
285
286
287
288
289
 
# File 'lib/haplocheirus/thrift/timeline_store.rb', line 280

def process_get(seqid, iprot, oprot)
  args = read_args(iprot, Get_args)
  result = Get_result.new()
  begin
    result.success = @handler.get(args.timeline_id, args.offset, args.length, args.dedupe)
  rescue Haplocheirus::TimelineStoreException => ex
    result.ex = ex
  end
  write_result(result, oprot, 'get', seqid)
end

#process_get_multi(seqid, iprot, oprot) ⇒ Object 



291
292
293
294
295
296
 
# File 'lib/haplocheirus/thrift/timeline_store.rb', line 291

def process_get_multi(seqid, iprot, oprot)
  args = read_args(iprot, Get_multi_args)
  result = Get_multi_result.new()
  result.success = @handler.get_multi(args.gets)
  write_result(result, oprot, 'get_multi', seqid)
end

#process_get_range(seqid, iprot, oprot) ⇒ Object 



298
299
300
301
302
303
304
305
306
307
 
# File 'lib/haplocheirus/thrift/timeline_store.rb', line 298

def process_get_range(seqid, iprot, oprot)
  args = read_args(iprot, Get_range_args)
  result = Get_range_result.new()
  begin
    result.success = @handler.get_range(args.timeline_id, args.from_id, args.to_id, args.dedupe)
  rescue Haplocheirus::TimelineStoreException => ex
    result.ex = ex
  end
  write_result(result, oprot, 'get_range', seqid)
end

#process_get_range_multi(seqid, iprot, oprot) ⇒ Object 



309
310
311
312
313
314
 
# File 'lib/haplocheirus/thrift/timeline_store.rb', line 309

def process_get_range_multi(seqid, iprot, oprot)
  args = read_args(iprot, Get_range_multi_args)
  result = Get_range_multi_result.new()
  result.success = @handler.get_range_multi(args.get_ranges)
  write_result(result, oprot, 'get_range_multi', seqid)
end

#process_merge(seqid, iprot, oprot) ⇒ Object 



327
328
329
330
331
332
333
334
335
336
 
# File 'lib/haplocheirus/thrift/timeline_store.rb', line 327

def process_merge(seqid, iprot, oprot)
  args = read_args(iprot, Merge_args)
  result = Merge_result.new()
  begin
    @handler.merge(args.timeline_id, args.entries)
  rescue Haplocheirus::TimelineStoreException => ex
    result.ex = ex
  end
  write_result(result, oprot, 'merge', seqid)
end

#process_merge_indirect(seqid, iprot, oprot) ⇒ Object 



349
350
351
352
353
354
355
356
357
358
 
# File 'lib/haplocheirus/thrift/timeline_store.rb', line 349

def process_merge_indirect(seqid, iprot, oprot)
  args = read_args(iprot, Merge_indirect_args)
  result = Merge_indirect_result.new()
  begin
    result.success = @handler.merge_indirect(args.dest_timeline_id, args.source_timeline_id)
  rescue Haplocheirus::TimelineStoreException => ex
    result.ex = ex
  end
  write_result(result, oprot, 'merge_indirect', seqid)
end

#process_remove(seqid, iprot, oprot) ⇒ Object 



247
248
249
250
251
252
253
254
255
256
 
# File 'lib/haplocheirus/thrift/timeline_store.rb', line 247

def process_remove(seqid, iprot, oprot)
  args = read_args(iprot, Remove_args)
  result = Remove_result.new()
  begin
    @handler.remove(args.entry, args.timeline_prefix, args.timeline_ids)
  rescue Haplocheirus::TimelineStoreException => ex
    result.ex = ex
  end
  write_result(result, oprot, 'remove', seqid)
end

#process_store(seqid, iprot, oprot) ⇒ Object 



316
317
318
319
320
321
322
323
324
325
 
# File 'lib/haplocheirus/thrift/timeline_store.rb', line 316

def process_store(seqid, iprot, oprot)
  args = read_args(iprot, Store_args)
  result = Store_result.new()
  begin
    @handler.store(args.timeline_id, args.entries)
  rescue Haplocheirus::TimelineStoreException => ex
    result.ex = ex
  end
  write_result(result, oprot, 'store', seqid)
end

#process_unmerge(seqid, iprot, oprot) ⇒ Object 



338
339
340
341
342
343
344
345
346
347
 
# File 'lib/haplocheirus/thrift/timeline_store.rb', line 338

def process_unmerge(seqid, iprot, oprot)
  args = read_args(iprot, Unmerge_args)
  result = Unmerge_result.new()
  begin
    @handler.unmerge(args.timeline_id, args.entries)
  rescue Haplocheirus::TimelineStoreException => ex
    result.ex = ex
  end
  write_result(result, oprot, 'unmerge', seqid)
end

#process_unmerge_indirect(seqid, iprot, oprot) ⇒ Object 



360
361
362
363
364
365
366
367
368
369
 
# File 'lib/haplocheirus/thrift/timeline_store.rb', line 360

def process_unmerge_indirect(seqid, iprot, oprot)
  args = read_args(iprot, Unmerge_indirect_args)
  result = Unmerge_indirect_result.new()
  begin
    result.success = @handler.unmerge_indirect(args.dest_timeline_id, args.source_timeline_id)
  rescue Haplocheirus::TimelineStoreException => ex
    result.ex = ex
  end
  write_result(result, oprot, 'unmerge_indirect', seqid)
end