Class: Zipkin::ZipkinQuery::Processor

Inherits:
Object
  • Object
show all
Includes:
Thrift::Processor
Defined in:
lib/zipkin_query/zipkin_query.rb,
lib/thrift/thrift/gen-rb/zipkin_query.rb

Instance Method Summary collapse

Instance Method Details

#process_getDataTimeToLive(seqid, iprot, oprot) ⇒ Object 



464
465
466
467
468
469
470
471
472
473
 
# File 'lib/zipkin_query/zipkin_query.rb', line 464

def process_getDataTimeToLive(seqid, iprot, oprot)
  args = read_args(iprot, GetDataTimeToLive_args)
  result = GetDataTimeToLive_result.new()
  begin
    result.success = @handler.getDataTimeToLive()
  rescue ::Zipkin::QueryException => qe
    result.qe = qe
  end
  write_result(result, oprot, 'getDataTimeToLive', seqid)
end

#process_getDependencies(seqid, iprot, oprot) ⇒ Object 



475
476
477
478
479
480
481
482
483
484
 
# File 'lib/zipkin_query/zipkin_query.rb', line 475

def process_getDependencies(seqid, iprot, oprot)
  args = read_args(iprot, GetDependencies_args)
  result = GetDependencies_result.new()
  begin
    result.success = @handler.getDependencies(args.start_time, args.end_time)
  rescue ::Zipkin::QueryException => qe
    result.qe = qe
  end
  write_result(result, oprot, 'getDependencies', seqid)
end

#process_getServiceNames(seqid, iprot, oprot) ⇒ Object 



420
421
422
423
424
425
426
427
428
429
 
# File 'lib/zipkin_query/zipkin_query.rb', line 420

def process_getServiceNames(seqid, iprot, oprot)
  args = read_args(iprot, GetServiceNames_args)
  result = GetServiceNames_result.new()
  begin
    result.success = @handler.getServiceNames()
  rescue ::Zipkin::QueryException => qe
    result.qe = qe
  end
  write_result(result, oprot, 'getServiceNames', seqid)
end

#process_getServiceNamesToTraceIds(seqid, iprot, oprot) ⇒ Object 



515
516
517
518
519
520
 
# File 'lib/zipkin_query/zipkin_query.rb', line 515

def process_getServiceNamesToTraceIds(seqid, iprot, oprot)
  args = read_args(iprot, GetServiceNamesToTraceIds_args)
  result = GetServiceNamesToTraceIds_result.new()
  result.success = @handler.getServiceNamesToTraceIds(args.time_stamp, args.service_name, args.rpc_name)
  write_result(result, oprot, 'getServiceNamesToTraceIds', seqid)
end

#process_getSpanDurations(seqid, iprot, oprot) ⇒ Object 



508
509
510
511
512
513
 
# File 'lib/zipkin_query/zipkin_query.rb', line 508

def process_getSpanDurations(seqid, iprot, oprot)
  args = read_args(iprot, GetSpanDurations_args)
  result = GetSpanDurations_result.new()
  result.success = @handler.getSpanDurations(args.time_stamp, args.service_name, args.rpc_name)
  write_result(result, oprot, 'getSpanDurations', seqid)
end

#process_getSpanNames(seqid, iprot, oprot) ⇒ Object 



431
432
433
434
435
436
437
438
439
440
 
# File 'lib/zipkin_query/zipkin_query.rb', line 431

def process_getSpanNames(seqid, iprot, oprot)
  args = read_args(iprot, GetSpanNames_args)
  result = GetSpanNames_result.new()
  begin
    result.success = @handler.getSpanNames(args.service_name)
  rescue ::Zipkin::QueryException => qe
    result.qe = qe
  end
  write_result(result, oprot, 'getSpanNames', seqid)
end

#process_getTopAnnotations(seqid, iprot, oprot) ⇒ Object 



486
487
488
489
490
491
492
493
494
495
 
# File 'lib/zipkin_query/zipkin_query.rb', line 486

def process_getTopAnnotations(seqid, iprot, oprot)
  args = read_args(iprot, GetTopAnnotations_args)
  result = GetTopAnnotations_result.new()
  begin
    result.success = @handler.getTopAnnotations(args.service_name)
  rescue ::Zipkin::QueryException => qe
    result.qe = qe
  end
  write_result(result, oprot, 'getTopAnnotations', seqid)
end

#process_getTopKeyValueAnnotations(seqid, iprot, oprot) ⇒ Object 



497
498
499
500
501
502
503
504
505
506
 
# File 'lib/zipkin_query/zipkin_query.rb', line 497

def process_getTopKeyValueAnnotations(seqid, iprot, oprot)
  args = read_args(iprot, GetTopKeyValueAnnotations_args)
  result = GetTopKeyValueAnnotations_result.new()
  begin
    result.success = @handler.getTopKeyValueAnnotations(args.service_name)
  rescue ::Zipkin::QueryException => qe
    result.qe = qe
  end
  write_result(result, oprot, 'getTopKeyValueAnnotations', seqid)
end

#process_getTraceCombosByIds(seqid, iprot, oprot) ⇒ Object 



409
410
411
412
413
414
415
416
417
418
 
# File 'lib/zipkin_query/zipkin_query.rb', line 409

def process_getTraceCombosByIds(seqid, iprot, oprot)
  args = read_args(iprot, GetTraceCombosByIds_args)
  result = GetTraceCombosByIds_result.new()
  begin
    result.success = @handler.getTraceCombosByIds(args.trace_ids, args.adjust)
  rescue ::Zipkin::QueryException => qe
    result.qe = qe
  end
  write_result(result, oprot, 'getTraceCombosByIds', seqid)
end

#process_getTraceIds(seqid, iprot, oprot) ⇒ Object 



321
322
323
324
325
326
327
328
329
330
 
# File 'lib/zipkin_query/zipkin_query.rb', line 321

def process_getTraceIds(seqid, iprot, oprot)
  args = read_args(iprot, GetTraceIds_args)
  result = GetTraceIds_result.new()
  begin
    result.success = @handler.getTraceIds(args.request)
  rescue ::Zipkin::QueryException => qe
    result.qe = qe
  end
  write_result(result, oprot, 'getTraceIds', seqid)
end

#process_getTraceIdsByAnnotation(seqid, iprot, oprot) ⇒ Object 



354
355
356
357
358
359
360
361
362
363
 
# File 'lib/zipkin_query/zipkin_query.rb', line 354

def process_getTraceIdsByAnnotation(seqid, iprot, oprot)
  args = read_args(iprot, GetTraceIdsByAnnotation_args)
  result = GetTraceIdsByAnnotation_result.new()
  begin
    result.success = @handler.getTraceIdsByAnnotation(args.service_name, args.annotation, args.value, args.end_ts, args.limit, args.order, args.start_ts)
  rescue ::Zipkin::QueryException => qe
    result.qe = qe
  end
  write_result(result, oprot, 'getTraceIdsByAnnotation', seqid)
end

#process_getTraceIdsByServiceName(seqid, iprot, oprot) ⇒ Object 



343
344
345
346
347
348
349
350
351
352
 
# File 'lib/zipkin_query/zipkin_query.rb', line 343

def process_getTraceIdsByServiceName(seqid, iprot, oprot)
  args = read_args(iprot, GetTraceIdsByServiceName_args)
  result = GetTraceIdsByServiceName_result.new()
  begin
    result.success = @handler.getTraceIdsByServiceName(args.service_name, args.end_ts, args.limit, args.order, args.start_ts)
  rescue ::Zipkin::QueryException => qe
    result.qe = qe
  end
  write_result(result, oprot, 'getTraceIdsByServiceName', seqid)
end

#process_getTraceIdsBySpanName(seqid, iprot, oprot) ⇒ Object 



332
333
334
335
336
337
338
339
340
341
 
# File 'lib/zipkin_query/zipkin_query.rb', line 332

def process_getTraceIdsBySpanName(seqid, iprot, oprot)
  args = read_args(iprot, GetTraceIdsBySpanName_args)
  result = GetTraceIdsBySpanName_result.new()
  begin
    result.success = @handler.getTraceIdsBySpanName(args.service_name, args.span_name, args.end_ts, args.limit, args.order, args.start_ts)
  rescue ::Zipkin::QueryException => qe
    result.qe = qe
  end
  write_result(result, oprot, 'getTraceIdsBySpanName', seqid)
end

#process_getTracesByIds(seqid, iprot, oprot) ⇒ Object 



376
377
378
379
380
381
382
383
384
385
 
# File 'lib/zipkin_query/zipkin_query.rb', line 376

def process_getTracesByIds(seqid, iprot, oprot)
  args = read_args(iprot, GetTracesByIds_args)
  result = GetTracesByIds_result.new()
  begin
    result.success = @handler.getTracesByIds(args.trace_ids, args.adjust)
  rescue ::Zipkin::QueryException => qe
    result.qe = qe
  end
  write_result(result, oprot, 'getTracesByIds', seqid)
end

#process_getTraceSummariesByIds(seqid, iprot, oprot) ⇒ Object 



398
399
400
401
402
403
404
405
406
407
 
# File 'lib/zipkin_query/zipkin_query.rb', line 398

def process_getTraceSummariesByIds(seqid, iprot, oprot)
  args = read_args(iprot, GetTraceSummariesByIds_args)
  result = GetTraceSummariesByIds_result.new()
  begin
    result.success = @handler.getTraceSummariesByIds(args.trace_ids, args.adjust)
  rescue ::Zipkin::QueryException => qe
    result.qe = qe
  end
  write_result(result, oprot, 'getTraceSummariesByIds', seqid)
end

#process_getTraceTimelinesByIds(seqid, iprot, oprot) ⇒ Object 



387
388
389
390
391
392
393
394
395
396
 
# File 'lib/zipkin_query/zipkin_query.rb', line 387

def process_getTraceTimelinesByIds(seqid, iprot, oprot)
  args = read_args(iprot, GetTraceTimelinesByIds_args)
  result = GetTraceTimelinesByIds_result.new()
  begin
    result.success = @handler.getTraceTimelinesByIds(args.trace_ids, args.adjust)
  rescue ::Zipkin::QueryException => qe
    result.qe = qe
  end
  write_result(result, oprot, 'getTraceTimelinesByIds', seqid)
end

#process_getTraceTimeToLive(seqid, iprot, oprot) ⇒ Object 



453
454
455
456
457
458
459
460
461
462
 
# File 'lib/zipkin_query/zipkin_query.rb', line 453

def process_getTraceTimeToLive(seqid, iprot, oprot)
  args = read_args(iprot, GetTraceTimeToLive_args)
  result = GetTraceTimeToLive_result.new()
  begin
    result.success = @handler.getTraceTimeToLive(args.trace_id)
  rescue ::Zipkin::QueryException => qe
    result.qe = qe
  end
  write_result(result, oprot, 'getTraceTimeToLive', seqid)
end

#process_setTraceTimeToLive(seqid, iprot, oprot) ⇒ Object 



442
443
444
445
446
447
448
449
450
451
 
# File 'lib/zipkin_query/zipkin_query.rb', line 442

def process_setTraceTimeToLive(seqid, iprot, oprot)
  args = read_args(iprot, SetTraceTimeToLive_args)
  result = SetTraceTimeToLive_result.new()
  begin
    @handler.setTraceTimeToLive(args.trace_id, args.ttl_seconds)
  rescue ::Zipkin::QueryException => qe
    result.qe = qe
  end
  write_result(result, oprot, 'setTraceTimeToLive', seqid)
end

#process_tracesExist(seqid, iprot, oprot) ⇒ Object 



365
366
367
368
369
370
371
372
373
374
 
# File 'lib/zipkin_query/zipkin_query.rb', line 365

def process_tracesExist(seqid, iprot, oprot)
  args = read_args(iprot, TracesExist_args)
  result = TracesExist_result.new()
  begin
    result.success = @handler.tracesExist(args.trace_ids)
  rescue ::Zipkin::QueryException => qe
    result.qe = qe
  end
  write_result(result, oprot, 'tracesExist', seqid)
end