Sha256: c074318feb761e3365693db4786f3fa78096e622c5e16a68f10cc70dbe202621
Contents?: true
Size: 1.14 KB
Versions: 5
Compression:
Stored size: 1.14 KB
Contents
#!/usr/bin/env ruby
require 'bundler'
Bundler.setup
require 'jaeger/client'
host = ENV['JAEGER_HOST'] || '127.0.0.1'
port = ENV['JAEGER_HOST'] || 6831
tracer1 = Jaeger::Client.build(host: host, port: port.to_i, service_name: 'test-service', flush_interval: 1)
tracer2 = Jaeger::Client.build(host: host, port: port.to_i, service_name: 'downstream-service', flush_interval: 1)
outer_span = tracer1.start_span(
'receive request',
tags: { 'span.kind' => 'server' }
)
sleep 0.1
outer_span.log_kv(event: 'woop di doop', count: 5)
sleep 1
inner_span = tracer1.start_span(
'fetch info from downstream',
child_of: outer_span,
tags: {
'span.kind' => 'client',
'peer.service' => 'downstream-service',
'peer.ipv4' => '6.6.6.6',
'peer.port' => 443
}
)
inner_span.set_tag('error', false)
sleep 0.3 # emulate network delay
downstream_span = tracer2.start_span(
'downstream operation',
child_of: inner_span,
tags: { 'span.kind' => 'server' }
)
sleep 0.5
downstream_span.finish
sleep 0.2 # emulate network delay
inner_span.finish
sleep 0.1 # doing something with fetched info
outer_span.finish
tracer1.stop
tracer2.stop
puts 'Finished'
Version data entries
5 entries across 5 versions & 2 rubygems