Class: Zipkin::ZipkinQuery::Processor

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

Instance Method Summary collapse

Instance Method Details

#process_getDataTimeToLive(seqid, iprot, oprot) ⇒ Object 



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

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 



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

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 



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

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 



517
518
519
520
521
522
 
# File 'lib/zipkin_query/zipkin_query.rb', line 517

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 



510
511
512
513
514
515
 
# File 'lib/zipkin_query/zipkin_query.rb', line 510

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 



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

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 



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

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 



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

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 



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

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 



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

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 



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

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)
  rescue ::Zipkin::QueryException => qe
    result.qe = qe
  end
  write_result(result, oprot, 'getTraceIdsByAnnotation', seqid)
end

#process_getTraceIdsByServiceName(seqid, iprot, oprot) ⇒ Object 



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

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)
  rescue ::Zipkin::QueryException => qe
    result.qe = qe
  end
  write_result(result, oprot, 'getTraceIdsByServiceName', seqid)
end

#process_getTraceIdsBySpanName(seqid, iprot, oprot) ⇒ Object 



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

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)
  rescue ::Zipkin::QueryException => qe
    result.qe = qe
  end
  write_result(result, oprot, 'getTraceIdsBySpanName', seqid)
end

#process_getTracesByIds(seqid, iprot, oprot) ⇒ Object 



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

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 



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

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 



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

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 



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

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 



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

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 



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

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