Sha256: cb9637eca84f5b59588548e8995d20465792a937955b085db6510a3bd806dcdd
Contents?: true
Size: 1.68 KB
Versions: 15
Compression:
Stored size: 1.68 KB
Contents
# frozen_string_literal: true
require "base64"
require "json"
require "uri"
module Honeycomb
# Parse trace headers
module PropagationParser
def parse(serialized_trace)
unless serialized_trace.nil?
version, payload = serialized_trace.split(";", 2)
if version == "1"
trace_id, parent_span_id, trace_fields, dataset = parse_v1(payload)
if !trace_id.nil? && !parent_span_id.nil?
return [trace_id, parent_span_id, trace_fields, dataset]
end
end
end
[nil, nil, nil, nil]
end
def parse_v1(payload)
trace_id, parent_span_id, trace_fields, dataset = nil
payload.split(",").each do |entry|
key, value = entry.split("=", 2)
case key
when "dataset"
dataset = URI.decode_www_form_component(value)
when "trace_id"
trace_id = value
when "parent_id"
parent_span_id = value
when "context"
Base64.decode64(value).tap do |json|
begin
trace_fields = JSON.parse json
rescue JSON::ParserError
trace_fields = {}
end
end
end
end
[trace_id, parent_span_id, trace_fields, dataset]
end
end
# Serialize trace headers
module PropagationSerializer
def to_trace_header
context = Base64.urlsafe_encode64(JSON.generate(trace.fields)).strip
encoded_dataset = URI.encode_www_form_component(builder.dataset)
data_to_propogate = [
"dataset=#{encoded_dataset}",
"trace_id=#{trace.id}",
"parent_id=#{id}",
"context=#{context}",
]
"1;#{data_to_propogate.join(',')}"
end
end
end
Version data entries
15 entries across 15 versions & 1 rubygems