Sha256: 6f0f02089de3e9943302ce4e5bfedb15b72b0a21289cac9d9c472ef6243d453c
Contents?: true
Size: 1.71 KB
Versions: 16
Compression:
Stored size: 1.71 KB
Contents
# frozen_string_literal: true
# Copyright The OpenTelemetry Authors
#
# SPDX-License-Identifier: Apache-2.0
module OpenTelemetry
module Instrumentation
module Rack
module Util
# QueueTime simply...
module QueueTime
REQUEST_START = 'HTTP_X_REQUEST_START'
QUEUE_START = 'HTTP_X_QUEUE_START'
MINIMUM_ACCEPTABLE_TIME_VALUE = 1_000_000_000
module_function
def get_request_start(env, now = nil) # rubocop:disable Metrics/AbcSize, Metrics/CyclomaticComplexity, Metrics/PerceivedComplexity
header = env[REQUEST_START] || env[QUEUE_START]
return unless header
# nginx header is seconds in the format "t=1512379167.574"
# apache header is microseconds in the format "t=1570633834463123"
# heroku header is milliseconds in the format "1570634024294"
time_string = header.to_s.delete('^0-9')
return if time_string.nil?
# Return nil if the time is clearly invalid
time_value = "#{time_string[0, 10]}.#{time_string[10, 6]}".to_f
return if time_value.zero? || time_value < MINIMUM_ACCEPTABLE_TIME_VALUE
# return the request_start only if it's lesser than
# current time, to avoid significant clock skew
request_start = Time.at(time_value)
now ||= Time.now.utc
request_start.utc > now ? nil : request_start
rescue StandardError => e
# in case of an Exception we don't create a
# `request.queuing` span
OpenTelemetry.logger.debug("[rack] unable to parse request queue headers: #{e}")
nil
end
end
end
end
end
end
Version data entries
16 entries across 16 versions & 1 rubygems