Contents

module Zipkin
  class Collector
    module LogAnnotations
      def self.build(span, endpoint)
        span.logs.map do |log|
          {
            timestamp: Timestamp.create(log.fetch(:timestamp)),
            value: format_log_value(log),
            endpoint: endpoint
          }
        end
      end

      def self.format_log_value(log)
        if log.keys == %i[event timestamp]
          log.fetch(:event)
        else
          log
            .reject { |key, _value| key == :timestamp }
            .map { |key, value| "#{key}=#{value}" }
            .join(' ')
        end
      end
    end
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
zipkin-1.2.0	lib/zipkin/collector/log_annotations.rb