mirror of
https://github.com/hanzoai/traces.git
synced 2026-10-30 18:20:41 +00:00
JaviandGitHub
5ba6c3c285
* update otel * update otel-collector-contrib * rollback upgrade of jaegerreceiver and kafkareceiver * fix go.sum * update opentelemetry-collector-contrib and jaegertracing * fix factory initialization * fix e2e * use the new jaeger definitions * fix factory initialization for otelexporter * use proper prefix * fix metric matcher for integration tests * changelog
38 lines
1.1 KiB
Go
38 lines
1.1 KiB
Go
// Copyright (c) 2019 The Jaeger Authors.
|
|
// Copyright (c) 2017 Uber Technologies, Inc.
|
|
// SPDX-License-Identifier: Apache-2.0
|
|
|
|
package model
|
|
|
|
import (
|
|
"time"
|
|
)
|
|
|
|
// EpochMicrosecondsAsTime converts microseconds since epoch to time.Time value.
|
|
func EpochMicrosecondsAsTime(ts uint64) time.Time {
|
|
seconds := ts / 1000000
|
|
nanos := 1000 * (ts % 1000000)
|
|
//nolint: gosec // G115
|
|
return time.Unix(int64(seconds), int64(nanos)).UTC()
|
|
}
|
|
|
|
// TimeAsEpochMicroseconds converts time.Time to microseconds since epoch,
|
|
// which is the format the StartTime field is stored in the Span.
|
|
func TimeAsEpochMicroseconds(t time.Time) uint64 {
|
|
//nolint: gosec // G115
|
|
return uint64(t.UnixNano() / 1000)
|
|
}
|
|
|
|
// MicrosecondsAsDuration converts duration in microseconds to time.Duration value.
|
|
func MicrosecondsAsDuration(v uint64) time.Duration {
|
|
//nolint: gosec // G115
|
|
return time.Duration(v) * time.Microsecond
|
|
}
|
|
|
|
// DurationAsMicroseconds converts time.Duration to microseconds,
|
|
// which is the format the Duration field is stored in the Span.
|
|
func DurationAsMicroseconds(d time.Duration) uint64 {
|
|
//nolint: gosec // G115
|
|
return uint64(d.Nanoseconds() / 1000)
|
|
}
|