Contents

#!/usr/bin/env ruby
# frozen_string_literal: true

require 'bundler'
Bundler.setup

require 'zipkin/tracer'

url = ENV['ZIPKIN_URL'] || 'http://localhost:9411'

tracer1 = Zipkin::Tracer.build(url: url, service_name: 'test-service', flush_interval: 1)
tracer2 = Zipkin::Tracer.build(url: url, service_name: 'downstream-service-1', flush_interval: 1)

root_span = tracer1.start_span(
  'receive request',
  tags: {
    'span.kind' => 'server'
  }
)
sleep 1

fetch_info_from_service1_span = tracer1.start_span(
  'fetch info from service 1',
  child_of: root_span,
  tags: {
    'span.kind' => 'client',
    'peer.ipv4' => '2.2.2.2',
    'peer.port' => 443
  }
)
sleep 0.3 # emulate network delay

service1_span = tracer2.start_span(
  'service 1 operation',
  child_of: fetch_info_from_service1_span,
  tags: {
    'span.kind' => 'server',
    'peer.ipv4' => '1.1.1.1',
    'peer.port' => 443
  }
)
service1_span.log_kv(event: 'custom-event')
service1_span.log_kv(foo: 'bar', baz: 'buz')
sleep 0.5
service1_span.finish

sleep 0.2 # emulate network delay

fetch_info_from_service1_span.finish

fetch_info_from_service2_span = tracer1.start_span(
  'fetch info from service 2 which does not have tracing',
  child_of: root_span,
  tags: {
    'span.kind' => 'client',
    'peer.service' => 'downstream-service-2',
    'peer.ipv4' => '3.3.3.3',
    'peer.port' => 443
  }
)
sleep 0.3 # emulate network delay
fetch_info_from_service2_span.finish

sleep 0.1 # doing something with fetched info
root_span.finish

puts 'Finishing...'
sleep 3

puts 'Finished'

Version data entries

3 entries across 3 versions & 1 rubygems

Version	Path
zipkin-1.6.3	script/create_trace
zipkin-1.6.2	script/create_trace
zipkin-1.6.1	script/create_trace