summaryrefslogtreecommitdiff
path: root/vendor/go.opentelemetry.io/auto
diff options
context:
space:
mode:
authorLibravatar Terin Stock <terinjokes@gmail.com>2025-03-09 17:47:56 +0100
committerLibravatar Terin Stock <terinjokes@gmail.com>2025-03-10 01:59:49 +0100
commit3ac1ee16f377d31a0fb80c8dae28b6239ac4229e (patch)
treef61faa581feaaeaba2542b9f2b8234a590684413 /vendor/go.opentelemetry.io/auto
parent[chore] update URLs to forked source (diff)
downloadgotosocial-3ac1ee16f377d31a0fb80c8dae28b6239ac4229e.tar.xz
[chore] remove vendor
Diffstat (limited to 'vendor/go.opentelemetry.io/auto')
-rw-r--r--vendor/go.opentelemetry.io/auto/sdk/CONTRIBUTING.md27
-rw-r--r--vendor/go.opentelemetry.io/auto/sdk/LICENSE201
-rw-r--r--vendor/go.opentelemetry.io/auto/sdk/VERSIONING.md15
-rw-r--r--vendor/go.opentelemetry.io/auto/sdk/doc.go14
-rw-r--r--vendor/go.opentelemetry.io/auto/sdk/internal/telemetry/attr.go58
-rw-r--r--vendor/go.opentelemetry.io/auto/sdk/internal/telemetry/doc.go8
-rw-r--r--vendor/go.opentelemetry.io/auto/sdk/internal/telemetry/id.go103
-rw-r--r--vendor/go.opentelemetry.io/auto/sdk/internal/telemetry/number.go67
-rw-r--r--vendor/go.opentelemetry.io/auto/sdk/internal/telemetry/resource.go66
-rw-r--r--vendor/go.opentelemetry.io/auto/sdk/internal/telemetry/scope.go67
-rw-r--r--vendor/go.opentelemetry.io/auto/sdk/internal/telemetry/span.go456
-rw-r--r--vendor/go.opentelemetry.io/auto/sdk/internal/telemetry/status.go40
-rw-r--r--vendor/go.opentelemetry.io/auto/sdk/internal/telemetry/traces.go189
-rw-r--r--vendor/go.opentelemetry.io/auto/sdk/internal/telemetry/value.go452
-rw-r--r--vendor/go.opentelemetry.io/auto/sdk/limit.go94
-rw-r--r--vendor/go.opentelemetry.io/auto/sdk/span.go432
-rw-r--r--vendor/go.opentelemetry.io/auto/sdk/tracer.go124
-rw-r--r--vendor/go.opentelemetry.io/auto/sdk/tracer_provider.go33
18 files changed, 0 insertions, 2446 deletions
diff --git a/vendor/go.opentelemetry.io/auto/sdk/CONTRIBUTING.md b/vendor/go.opentelemetry.io/auto/sdk/CONTRIBUTING.md
deleted file mode 100644
index 773c9b643..000000000
--- a/vendor/go.opentelemetry.io/auto/sdk/CONTRIBUTING.md
+++ /dev/null
@@ -1,27 +0,0 @@
-# Contributing to go.opentelemetry.io/auto/sdk
-
-The `go.opentelemetry.io/auto/sdk` module is a purpose built OpenTelemetry SDK.
-It is designed to be:
-
-0. An OpenTelemetry compliant SDK
-1. Instrumented by auto-instrumentation (serializable into OTLP JSON)
-2. Lightweight
-3. User-friendly
-
-These design choices are listed in the order of their importance.
-
-The primary design goal of this module is to be an OpenTelemetry SDK.
-This means that it needs to implement the Go APIs found in `go.opentelemetry.io/otel`.
-
-Having met the requirement of SDK compliance, this module needs to provide code that the `go.opentelemetry.io/auto` module can instrument.
-The chosen approach to meet this goal is to ensure the telemetry from the SDK is serializable into JSON encoded OTLP.
-This ensures then that the serialized form is compatible with other OpenTelemetry systems, and the auto-instrumentation can use these systems to deserialize any telemetry it is sent.
-
-Outside of these first two goals, the intended use becomes relevant.
-This package is intended to be used in the `go.opentelemetry.io/otel` global API as a default when the auto-instrumentation is running.
-Because of this, this package needs to not add unnecessary dependencies to that API.
-Ideally, it adds none.
-It also needs to operate efficiently.
-
-Finally, this module is designed to be user-friendly to Go development.
-It hides complexity in order to provide simpler APIs when the previous goals can all still be met.
diff --git a/vendor/go.opentelemetry.io/auto/sdk/LICENSE b/vendor/go.opentelemetry.io/auto/sdk/LICENSE
deleted file mode 100644
index 261eeb9e9..000000000
--- a/vendor/go.opentelemetry.io/auto/sdk/LICENSE
+++ /dev/null
@@ -1,201 +0,0 @@
- Apache License
- Version 2.0, January 2004
- http://www.apache.org/licenses/
-
- TERMS AND CONDITIONS FOR USE, REPRODUCTION, AND DISTRIBUTION
-
- 1. Definitions.
-
- "License" shall mean the terms and conditions for use, reproduction,
- and distribution as defined by Sections 1 through 9 of this document.
-
- "Licensor" shall mean the copyright owner or entity authorized by
- the copyright owner that is granting the License.
-
- "Legal Entity" shall mean the union of the acting entity and all
- other entities that control, are controlled by, or are under common
- control with that entity. For the purposes of this definition,
- "control" means (i) the power, direct or indirect, to cause the
- direction or management of such entity, whether by contract or
- otherwise, or (ii) ownership of fifty percent (50%) or more of the
- outstanding shares, or (iii) beneficial ownership of such entity.
-
- "You" (or "Your") shall mean an individual or Legal Entity
- exercising permissions granted by this License.
-
- "Source" form shall mean the preferred form for making modifications,
- including but not limited to software source code, documentation
- source, and configuration files.
-
- "Object" form shall mean any form resulting from mechanical
- transformation or translation of a Source form, including but
- not limited to compiled object code, generated documentation,
- and conversions to other media types.
-
- "Work" shall mean the work of authorship, whether in Source or
- Object form, made available under the License, as indicated by a
- copyright notice that is included in or attached to the work
- (an example is provided in the Appendix below).
-
- "Derivative Works" shall mean any work, whether in Source or Object
- form, that is based on (or derived from) the Work and for which the
- editorial revisions, annotations, elaborations, or other modifications
- represent, as a whole, an original work of authorship. For the purposes
- of this License, Derivative Works shall not include works that remain
- separable from, or merely link (or bind by name) to the interfaces of,
- the Work and Derivative Works thereof.
-
- "Contribution" shall mean any work of authorship, including
- the original version of the Work and any modifications or additions
- to that Work or Derivative Works thereof, that is intentionally
- submitted to Licensor for inclusion in the Work by the copyright owner
- or by an individual or Legal Entity authorized to submit on behalf of
- the copyright owner. For the purposes of this definition, "submitted"
- means any form of electronic, verbal, or written communication sent
- to the Licensor or its representatives, including but not limited to
- communication on electronic mailing lists, source code control systems,
- and issue tracking systems that are managed by, or on behalf of, the
- Licensor for the purpose of discussing and improving the Work, but
- excluding communication that is conspicuously marked or otherwise
- designated in writing by the copyright owner as "Not a Contribution."
-
- "Contributor" shall mean Licensor and any individual or Legal Entity
- on behalf of whom a Contribution has been received by Licensor and
- subsequently incorporated within the Work.
-
- 2. Grant of Copyright License. Subject to the terms and conditions of
- this License, each Contributor hereby grants to You a perpetual,
- worldwide, non-exclusive, no-charge, royalty-free, irrevocable
- copyright license to reproduce, prepare Derivative Works of,
- publicly display, publicly perform, sublicense, and distribute the
- Work and such Derivative Works in Source or Object form.
-
- 3. Grant of Patent License. Subject to the terms and conditions of
- this License, each Contributor hereby grants to You a perpetual,
- worldwide, non-exclusive, no-charge, royalty-free, irrevocable
- (except as stated in this section) patent license to make, have made,
- use, offer to sell, sell, import, and otherwise transfer the Work,
- where such license applies only to those patent claims licensable
- by such Contributor that are necessarily infringed by their
- Contribution(s) alone or by combination of their Contribution(s)
- with the Work to which such Contribution(s) was submitted. If You
- institute patent litigation against any entity (including a
- cross-claim or counterclaim in a lawsuit) alleging that the Work
- or a Contribution incorporated within the Work constitutes direct
- or contributory patent infringement, then any patent licenses
- granted to You under this License for that Work shall terminate
- as of the date such litigation is filed.
-
- 4. Redistribution. You may reproduce and distribute copies of the
- Work or Derivative Works thereof in any medium, with or without
- modifications, and in Source or Object form, provided that You
- meet the following conditions:
-
- (a) You must give any other recipients of the Work or
- Derivative Works a copy of this License; and
-
- (b) You must cause any modified files to carry prominent notices
- stating that You changed the files; and
-
- (c) You must retain, in the Source form of any Derivative Works
- that You distribute, all copyright, patent, trademark, and
- attribution notices from the Source form of the Work,
- excluding those notices that do not pertain to any part of
- the Derivative Works; and
-
- (d) If the Work includes a "NOTICE" text file as part of its
- distribution, then any Derivative Works that You distribute must
- include a readable copy of the attribution notices contained
- within such NOTICE file, excluding those notices that do not
- pertain to any part of the Derivative Works, in at least one
- of the following places: within a NOTICE text file distributed
- as part of the Derivative Works; within the Source form or
- documentation, if provided along with the Derivative Works; or,
- within a display generated by the Derivative Works, if and
- wherever such third-party notices normally appear. The contents
- of the NOTICE file are for informational purposes only and
- do not modify the License. You may add Your own attribution
- notices within Derivative Works that You distribute, alongside
- or as an addendum to the NOTICE text from the Work, provided
- that such additional attribution notices cannot be construed
- as modifying the License.
-
- You may add Your own copyright statement to Your modifications and
- may provide additional or different license terms and conditions
- for use, reproduction, or distribution of Your modifications, or
- for any such Derivative Works as a whole, provided Your use,
- reproduction, and distribution of the Work otherwise complies with
- the conditions stated in this License.
-
- 5. Submission of Contributions. Unless You explicitly state otherwise,
- any Contribution intentionally submitted for inclusion in the Work
- by You to the Licensor shall be under the terms and conditions of
- this License, without any additional terms or conditions.
- Notwithstanding the above, nothing herein shall supersede or modify
- the terms of any separate license agreement you may have executed
- with Licensor regarding such Contributions.
-
- 6. Trademarks. This License does not grant permission to use the trade
- names, trademarks, service marks, or product names of the Licensor,
- except as required for reasonable and customary use in describing the
- origin of the Work and reproducing the content of the NOTICE file.
-
- 7. Disclaimer of Warranty. Unless required by applicable law or
- agreed to in writing, Licensor provides the Work (and each
- Contributor provides its Contributions) on an "AS IS" BASIS,
- WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or
- implied, including, without limitation, any warranties or conditions
- of TITLE, NON-INFRINGEMENT, MERCHANTABILITY, or FITNESS FOR A
- PARTICULAR PURPOSE. You are solely responsible for determining the
- appropriateness of using or redistributing the Work and assume any
- risks associated with Your exercise of permissions under this License.
-
- 8. Limitation of Liability. In no event and under no legal theory,
- whether in tort (including negligence), contract, or otherwise,
- unless required by applicable law (such as deliberate and grossly
- negligent acts) or agreed to in writing, shall any Contributor be
- liable to You for damages, including any direct, indirect, special,
- incidental, or consequential damages of any character arising as a
- result of this License or out of the use or inability to use the
- Work (including but not limited to damages for loss of goodwill,
- work stoppage, computer failure or malfunction, or any and all
- other commercial damages or losses), even if such Contributor
- has been advised of the possibility of such damages.
-
- 9. Accepting Warranty or Additional Liability. While redistributing
- the Work or Derivative Works thereof, You may choose to offer,
- and charge a fee for, acceptance of support, warranty, indemnity,
- or other liability obligations and/or rights consistent with this
- License. However, in accepting such obligations, You may act only
- on Your own behalf and on Your sole responsibility, not on behalf
- of any other Contributor, and only if You agree to indemnify,
- defend, and hold each Contributor harmless for any liability
- incurred by, or claims asserted against, such Contributor by reason
- of your accepting any such warranty or additional liability.
-
- END OF TERMS AND CONDITIONS
-
- APPENDIX: How to apply the Apache License to your work.
-
- To apply the Apache License to your work, attach the following
- boilerplate notice, with the fields enclosed by brackets "[]"
- replaced with your own identifying information. (Don't include
- the brackets!) The text should be enclosed in the appropriate
- comment syntax for the file format. We also recommend that a
- file or class name and description of purpose be included on the
- same "printed page" as the copyright notice for easier
- identification within third-party archives.
-
- Copyright [yyyy] [name of copyright owner]
-
- Licensed under the Apache License, Version 2.0 (the "License");
- you may not use this file except in compliance with the License.
- You may obtain a copy of the License at
-
- http://www.apache.org/licenses/LICENSE-2.0
-
- Unless required by applicable law or agreed to in writing, software
- distributed under the License is distributed on an "AS IS" BASIS,
- WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- See the License for the specific language governing permissions and
- limitations under the License.
diff --git a/vendor/go.opentelemetry.io/auto/sdk/VERSIONING.md b/vendor/go.opentelemetry.io/auto/sdk/VERSIONING.md
deleted file mode 100644
index 088d19a6c..000000000
--- a/vendor/go.opentelemetry.io/auto/sdk/VERSIONING.md
+++ /dev/null
@@ -1,15 +0,0 @@
-# Versioning
-
-This document describes the versioning policy for this module.
-This policy is designed so the following goals can be achieved.
-
-**Users are provided a codebase of value that is stable and secure.**
-
-## Policy
-
-* Versioning of this module will be idiomatic of a Go project using [Go modules](https://github.com/golang/go/wiki/Modules).
- * [Semantic import versioning](https://github.com/golang/go/wiki/Modules#semantic-import-versioning) will be used.
- * Versions will comply with [semver 2.0](https://semver.org/spec/v2.0.0.html).
- * Any `v2` or higher version of this module will be included as a `/vN` at the end of the module path used in `go.mod` files and in the package import path.
-
-* GitHub releases will be made for all releases.
diff --git a/vendor/go.opentelemetry.io/auto/sdk/doc.go b/vendor/go.opentelemetry.io/auto/sdk/doc.go
deleted file mode 100644
index ad73d8cb9..000000000
--- a/vendor/go.opentelemetry.io/auto/sdk/doc.go
+++ /dev/null
@@ -1,14 +0,0 @@
-// Copyright The OpenTelemetry Authors
-// SPDX-License-Identifier: Apache-2.0
-
-/*
-Package sdk provides an auto-instrumentable OpenTelemetry SDK.
-
-An [go.opentelemetry.io/auto.Instrumentation] can be configured to target the
-process running this SDK. In that case, all telemetry the SDK produces will be
-processed and handled by that [go.opentelemetry.io/auto.Instrumentation].
-
-By default, if there is no [go.opentelemetry.io/auto.Instrumentation] set to
-auto-instrument the SDK, the SDK will not generate any telemetry.
-*/
-package sdk
diff --git a/vendor/go.opentelemetry.io/auto/sdk/internal/telemetry/attr.go b/vendor/go.opentelemetry.io/auto/sdk/internal/telemetry/attr.go
deleted file mode 100644
index af6ef171f..000000000
--- a/vendor/go.opentelemetry.io/auto/sdk/internal/telemetry/attr.go
+++ /dev/null
@@ -1,58 +0,0 @@
-// Copyright The OpenTelemetry Authors
-// SPDX-License-Identifier: Apache-2.0
-
-package telemetry
-
-// Attr is a key-value pair.
-type Attr struct {
- Key string `json:"key,omitempty"`
- Value Value `json:"value,omitempty"`
-}
-
-// String returns an Attr for a string value.
-func String(key, value string) Attr {
- return Attr{key, StringValue(value)}
-}
-
-// Int64 returns an Attr for an int64 value.
-func Int64(key string, value int64) Attr {
- return Attr{key, Int64Value(value)}
-}
-
-// Int returns an Attr for an int value.
-func Int(key string, value int) Attr {
- return Int64(key, int64(value))
-}
-
-// Float64 returns an Attr for a float64 value.
-func Float64(key string, value float64) Attr {
- return Attr{key, Float64Value(value)}
-}
-
-// Bool returns an Attr for a bool value.
-func Bool(key string, value bool) Attr {
- return Attr{key, BoolValue(value)}
-}
-
-// Bytes returns an Attr for a []byte value.
-// The passed slice must not be changed after it is passed.
-func Bytes(key string, value []byte) Attr {
- return Attr{key, BytesValue(value)}
-}
-
-// Slice returns an Attr for a []Value value.
-// The passed slice must not be changed after it is passed.
-func Slice(key string, value ...Value) Attr {
- return Attr{key, SliceValue(value...)}
-}
-
-// Map returns an Attr for a map value.
-// The passed slice must not be changed after it is passed.
-func Map(key string, value ...Attr) Attr {
- return Attr{key, MapValue(value...)}
-}
-
-// Equal returns if a is equal to b.
-func (a Attr) Equal(b Attr) bool {
- return a.Key == b.Key && a.Value.Equal(b.Value)
-}
diff --git a/vendor/go.opentelemetry.io/auto/sdk/internal/telemetry/doc.go b/vendor/go.opentelemetry.io/auto/sdk/internal/telemetry/doc.go
deleted file mode 100644
index 949e2165c..000000000
--- a/vendor/go.opentelemetry.io/auto/sdk/internal/telemetry/doc.go
+++ /dev/null
@@ -1,8 +0,0 @@
-// Copyright The OpenTelemetry Authors
-// SPDX-License-Identifier: Apache-2.0
-
-/*
-Package telemetry provides a lightweight representations of OpenTelemetry
-telemetry that is compatible with the OTLP JSON protobuf encoding.
-*/
-package telemetry
diff --git a/vendor/go.opentelemetry.io/auto/sdk/internal/telemetry/id.go b/vendor/go.opentelemetry.io/auto/sdk/internal/telemetry/id.go
deleted file mode 100644
index e854d7e84..000000000
--- a/vendor/go.opentelemetry.io/auto/sdk/internal/telemetry/id.go
+++ /dev/null
@@ -1,103 +0,0 @@
-// Copyright The OpenTelemetry Authors
-// SPDX-License-Identifier: Apache-2.0
-
-package telemetry
-
-import (
- "encoding/hex"
- "errors"
- "fmt"
-)
-
-const (
- traceIDSize = 16
- spanIDSize = 8
-)
-
-// TraceID is a custom data type that is used for all trace IDs.
-type TraceID [traceIDSize]byte
-
-// String returns the hex string representation form of a TraceID.
-func (tid TraceID) String() string {
- return hex.EncodeToString(tid[:])
-}
-
-// IsEmpty returns false if id contains at least one non-zero byte.
-func (tid TraceID) IsEmpty() bool {
- return tid == [traceIDSize]byte{}
-}
-
-// MarshalJSON converts the trace ID into a hex string enclosed in quotes.
-func (tid TraceID) MarshalJSON() ([]byte, error) {
- if tid.IsEmpty() {
- return []byte(`""`), nil
- }
- return marshalJSON(tid[:])
-}
-
-// UnmarshalJSON inflates the trace ID from hex string, possibly enclosed in
-// quotes.
-func (tid *TraceID) UnmarshalJSON(data []byte) error {
- *tid = [traceIDSize]byte{}
- return unmarshalJSON(tid[:], data)
-}
-
-// SpanID is a custom data type that is used for all span IDs.
-type SpanID [spanIDSize]byte
-
-// String returns the hex string representation form of a SpanID.
-func (sid SpanID) String() string {
- return hex.EncodeToString(sid[:])
-}
-
-// IsEmpty returns true if the span ID contains at least one non-zero byte.
-func (sid SpanID) IsEmpty() bool {
- return sid == [spanIDSize]byte{}
-}
-
-// MarshalJSON converts span ID into a hex string enclosed in quotes.
-func (sid SpanID) MarshalJSON() ([]byte, error) {
- if sid.IsEmpty() {
- return []byte(`""`), nil
- }
- return marshalJSON(sid[:])
-}
-
-// UnmarshalJSON decodes span ID from hex string, possibly enclosed in quotes.
-func (sid *SpanID) UnmarshalJSON(data []byte) error {
- *sid = [spanIDSize]byte{}
- return unmarshalJSON(sid[:], data)
-}
-
-// marshalJSON converts id into a hex string enclosed in quotes.
-func marshalJSON(id []byte) ([]byte, error) {
- // Plus 2 quote chars at the start and end.
- hexLen := hex.EncodedLen(len(id)) + 2
-
- b := make([]byte, hexLen)
- hex.Encode(b[1:hexLen-1], id)
- b[0], b[hexLen-1] = '"', '"'
-
- return b, nil
-}
-
-// unmarshalJSON inflates trace id from hex string, possibly enclosed in quotes.
-func unmarshalJSON(dst []byte, src []byte) error {
- if l := len(src); l >= 2 && src[0] == '"' && src[l-1] == '"' {
- src = src[1 : l-1]
- }
- nLen := len(src)
- if nLen == 0 {
- return nil
- }
-
- if len(dst) != hex.DecodedLen(nLen) {
- return errors.New("invalid length for ID")
- }
-
- _, err := hex.Decode(dst, src)
- if err != nil {
- return fmt.Errorf("cannot unmarshal ID from string '%s': %w", string(src), err)
- }
- return nil
-}
diff --git a/vendor/go.opentelemetry.io/auto/sdk/internal/telemetry/number.go b/vendor/go.opentelemetry.io/auto/sdk/internal/telemetry/number.go
deleted file mode 100644
index 29e629d66..000000000
--- a/vendor/go.opentelemetry.io/auto/sdk/internal/telemetry/number.go
+++ /dev/null
@@ -1,67 +0,0 @@
-// Copyright The OpenTelemetry Authors
-// SPDX-License-Identifier: Apache-2.0
-
-package telemetry
-
-import (
- "encoding/json"
- "strconv"
-)
-
-// protoInt64 represents the protobuf encoding of integers which can be either
-// strings or integers.
-type protoInt64 int64
-
-// Int64 returns the protoInt64 as an int64.
-func (i *protoInt64) Int64() int64 { return int64(*i) }
-
-// UnmarshalJSON decodes both strings and integers.
-func (i *protoInt64) UnmarshalJSON(data []byte) error {
- if data[0] == '"' {
- var str string
- if err := json.Unmarshal(data, &str); err != nil {
- return err
- }
- parsedInt, err := strconv.ParseInt(str, 10, 64)
- if err != nil {
- return err
- }
- *i = protoInt64(parsedInt)
- } else {
- var parsedInt int64
- if err := json.Unmarshal(data, &parsedInt); err != nil {
- return err
- }
- *i = protoInt64(parsedInt)
- }
- return nil
-}
-
-// protoUint64 represents the protobuf encoding of integers which can be either
-// strings or integers.
-type protoUint64 uint64
-
-// Int64 returns the protoUint64 as a uint64.
-func (i *protoUint64) Uint64() uint64 { return uint64(*i) }
-
-// UnmarshalJSON decodes both strings and integers.
-func (i *protoUint64) UnmarshalJSON(data []byte) error {
- if data[0] == '"' {
- var str string
- if err := json.Unmarshal(data, &str); err != nil {
- return err
- }
- parsedUint, err := strconv.ParseUint(str, 10, 64)
- if err != nil {
- return err
- }
- *i = protoUint64(parsedUint)
- } else {
- var parsedUint uint64
- if err := json.Unmarshal(data, &parsedUint); err != nil {
- return err
- }
- *i = protoUint64(parsedUint)
- }
- return nil
-}
diff --git a/vendor/go.opentelemetry.io/auto/sdk/internal/telemetry/resource.go b/vendor/go.opentelemetry.io/auto/sdk/internal/telemetry/resource.go
deleted file mode 100644
index cecad8bae..000000000
--- a/vendor/go.opentelemetry.io/auto/sdk/internal/telemetry/resource.go
+++ /dev/null
@@ -1,66 +0,0 @@
-// Copyright The OpenTelemetry Authors
-// SPDX-License-Identifier: Apache-2.0
-
-package telemetry
-
-import (
- "bytes"
- "encoding/json"
- "errors"
- "fmt"
- "io"
-)
-
-// Resource information.
-type Resource struct {
- // Attrs are the set of attributes that describe the resource. Attribute
- // keys MUST be unique (it is not allowed to have more than one attribute
- // with the same key).
- Attrs []Attr `json:"attributes,omitempty"`
- // DroppedAttrs is the number of dropped attributes. If the value
- // is 0, then no attributes were dropped.
- DroppedAttrs uint32 `json:"droppedAttributesCount,omitempty"`
-}
-
-// UnmarshalJSON decodes the OTLP formatted JSON contained in data into r.
-func (r *Resource) UnmarshalJSON(data []byte) error {
- decoder := json.NewDecoder(bytes.NewReader(data))
-
- t, err := decoder.Token()
- if err != nil {
- return err
- }
- if t != json.Delim('{') {
- return errors.New("invalid Resource type")
- }
-
- for decoder.More() {
- keyIface, err := decoder.Token()
- if err != nil {
- if errors.Is(err, io.EOF) {
- // Empty.
- return nil
- }
- return err
- }
-
- key, ok := keyIface.(string)
- if !ok {
- return fmt.Errorf("invalid Resource field: %#v", keyIface)
- }
-
- switch key {
- case "attributes":
- err = decoder.Decode(&r.Attrs)
- case "droppedAttributesCount", "dropped_attributes_count":
- err = decoder.Decode(&r.DroppedAttrs)
- default:
- // Skip unknown.
- }
-
- if err != nil {
- return err
- }
- }
- return nil
-}
diff --git a/vendor/go.opentelemetry.io/auto/sdk/internal/telemetry/scope.go b/vendor/go.opentelemetry.io/auto/sdk/internal/telemetry/scope.go
deleted file mode 100644
index b6f2e28d4..000000000
--- a/vendor/go.opentelemetry.io/auto/sdk/internal/telemetry/scope.go
+++ /dev/null
@@ -1,67 +0,0 @@
-// Copyright The OpenTelemetry Authors
-// SPDX-License-Identifier: Apache-2.0
-
-package telemetry
-
-import (
- "bytes"
- "encoding/json"
- "errors"
- "fmt"
- "io"
-)
-
-// Scope is the identifying values of the instrumentation scope.
-type Scope struct {
- Name string `json:"name,omitempty"`
- Version string `json:"version,omitempty"`
- Attrs []Attr `json:"attributes,omitempty"`
- DroppedAttrs uint32 `json:"droppedAttributesCount,omitempty"`
-}
-
-// UnmarshalJSON decodes the OTLP formatted JSON contained in data into r.
-func (s *Scope) UnmarshalJSON(data []byte) error {
- decoder := json.NewDecoder(bytes.NewReader(data))
-
- t, err := decoder.Token()
- if err != nil {
- return err
- }
- if t != json.Delim('{') {
- return errors.New("invalid Scope type")
- }
-
- for decoder.More() {
- keyIface, err := decoder.Token()
- if err != nil {
- if errors.Is(err, io.EOF) {
- // Empty.
- return nil
- }
- return err
- }
-
- key, ok := keyIface.(string)
- if !ok {
- return fmt.Errorf("invalid Scope field: %#v", keyIface)
- }
-
- switch key {
- case "name":
- err = decoder.Decode(&s.Name)
- case "version":
- err = decoder.Decode(&s.Version)
- case "attributes":
- err = decoder.Decode(&s.Attrs)
- case "droppedAttributesCount", "dropped_attributes_count":
- err = decoder.Decode(&s.DroppedAttrs)
- default:
- // Skip unknown.
- }
-
- if err != nil {
- return err
- }
- }
- return nil
-}
diff --git a/vendor/go.opentelemetry.io/auto/sdk/internal/telemetry/span.go b/vendor/go.opentelemetry.io/auto/sdk/internal/telemetry/span.go
deleted file mode 100644
index a13a6b733..000000000
--- a/vendor/go.opentelemetry.io/auto/sdk/internal/telemetry/span.go
+++ /dev/null
@@ -1,456 +0,0 @@
-// Copyright The OpenTelemetry Authors
-// SPDX-License-Identifier: Apache-2.0
-
-package telemetry
-
-import (
- "bytes"
- "encoding/hex"
- "encoding/json"
- "errors"
- "fmt"
- "io"
- "time"
-)
-
-// A Span represents a single operation performed by a single component of the
-// system.
-type Span struct {
- // A unique identifier for a trace. All spans from the same trace share
- // the same `trace_id`. The ID is a 16-byte array. An ID with all zeroes OR
- // of length other than 16 bytes is considered invalid (empty string in OTLP/JSON
- // is zero-length and thus is also invalid).
- //
- // This field is required.
- TraceID TraceID `json:"traceId,omitempty"`
- // A unique identifier for a span within a trace, assigned when the span
- // is created. The ID is an 8-byte array. An ID with all zeroes OR of length
- // other than 8 bytes is considered invalid (empty string in OTLP/JSON
- // is zero-length and thus is also invalid).
- //
- // This field is required.
- SpanID SpanID `json:"spanId,omitempty"`
- // trace_state conveys information about request position in multiple distributed tracing graphs.
- // It is a trace_state in w3c-trace-context format: https://www.w3.org/TR/trace-context/#tracestate-header
- // See also https://github.com/w3c/distributed-tracing for more details about this field.
- TraceState string `json:"traceState,omitempty"`
- // The `span_id` of this span's parent span. If this is a root span, then this
- // field must be empty. The ID is an 8-byte array.
- ParentSpanID SpanID `json:"parentSpanId,omitempty"`
- // Flags, a bit field.
- //
- // Bits 0-7 (8 least significant bits) are the trace flags as defined in W3C Trace
- // Context specification. To read the 8-bit W3C trace flag, use
- // `flags & SPAN_FLAGS_TRACE_FLAGS_MASK`.
- //
- // See https://www.w3.org/TR/trace-context-2/#trace-flags for the flag definitions.
- //
- // Bits 8 and 9 represent the 3 states of whether a span's parent
- // is remote. The states are (unknown, is not remote, is remote).
- // To read whether the value is known, use `(flags & SPAN_FLAGS_CONTEXT_HAS_IS_REMOTE_MASK) != 0`.
- // To read whether the span is remote, use `(flags & SPAN_FLAGS_CONTEXT_IS_REMOTE_MASK) != 0`.
- //
- // When creating span messages, if the message is logically forwarded from another source
- // with an equivalent flags fields (i.e., usually another OTLP span message), the field SHOULD
- // be copied as-is. If creating from a source that does not have an equivalent flags field
- // (such as a runtime representation of an OpenTelemetry span), the high 22 bits MUST
- // be set to zero.
- // Readers MUST NOT assume that bits 10-31 (22 most significant bits) will be zero.
- //
- // [Optional].
- Flags uint32 `json:"flags,omitempty"`
- // A description of the span's operation.
- //
- // For example, the name can be a qualified method name or a file name
- // and a line number where the operation is called. A best practice is to use
- // the same display name at the same call point in an application.
- // This makes it easier to correlate spans in different traces.
- //
- // This field is semantically required to be set to non-empty string.
- // Empty value is equivalent to an unknown span name.
- //
- // This field is required.
- Name string `json:"name"`
- // Distinguishes between spans generated in a particular context. For example,
- // two spans with the same name may be distinguished using `CLIENT` (caller)
- // and `SERVER` (callee) to identify queueing latency associated with the span.
- Kind SpanKind `json:"kind,omitempty"`
- // start_time_unix_nano is the start time of the span. On the client side, this is the time
- // kept by the local machine where the span execution starts. On the server side, this
- // is the time when the server's application handler starts running.
- // Value is UNIX Epoch time in nanoseconds since 00:00:00 UTC on 1 January 1970.
- //
- // This field is semantically required and it is expected that end_time >= start_time.
- StartTime time.Time `json:"startTimeUnixNano,omitempty"`
- // end_time_unix_nano is the end time of the span. On the client side, this is the time
- // kept by the local machine where the span execution ends. On the server side, this
- // is the time when the server application handler stops running.
- // Value is UNIX Epoch time in nanoseconds since 00:00:00 UTC on 1 January 1970.
- //
- // This field is semantically required and it is expected that end_time >= start_time.
- EndTime time.Time `json:"endTimeUnixNano,omitempty"`
- // attributes is a collection of key/value pairs. Note, global attributes
- // like server name can be set using the resource API. Examples of attributes:
- //
- // "/http/user_agent": "Mozilla/5.0 (Macintosh; Intel Mac OS X 10_14_2) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/71.0.3578.98 Safari/537.36"
- // "/http/server_latency": 300
- // "example.com/myattribute": true
- // "example.com/score": 10.239
- //
- // The OpenTelemetry API specification further restricts the allowed value types:
- // https://github.com/open-telemetry/opentelemetry-specification/blob/main/specification/common/README.md#attribute
- // Attribute keys MUST be unique (it is not allowed to have more than one
- // attribute with the same key).
- Attrs []Attr `json:"attributes,omitempty"`
- // dropped_attributes_count is the number of attributes that were discarded. Attributes
- // can be discarded because their keys are too long or because there are too many
- // attributes. If this value is 0, then no attributes were dropped.
- DroppedAttrs uint32 `json:"droppedAttributesCount,omitempty"`
- // events is a collection of Event items.
- Events []*SpanEvent `json:"events,omitempty"`
- // dropped_events_count is the number of dropped events. If the value is 0, then no
- // events were dropped.
- DroppedEvents uint32 `json:"droppedEventsCount,omitempty"`
- // links is a collection of Links, which are references from this span to a span
- // in the same or different trace.
- Links []*SpanLink `json:"links,omitempty"`
- // dropped_links_count is the number of dropped links after the maximum size was
- // enforced. If this value is 0, then no links were dropped.
- DroppedLinks uint32 `json:"droppedLinksCount,omitempty"`
- // An optional final status for this span. Semantically when Status isn't set, it means
- // span's status code is unset, i.e. assume STATUS_CODE_UNSET (code = 0).
- Status *Status `json:"status,omitempty"`
-}
-
-// MarshalJSON encodes s into OTLP formatted JSON.
-func (s Span) MarshalJSON() ([]byte, error) {
- startT := s.StartTime.UnixNano()
- if s.StartTime.IsZero() || startT < 0 {
- startT = 0
- }
-
- endT := s.EndTime.UnixNano()
- if s.EndTime.IsZero() || endT < 0 {
- endT = 0
- }
-
- // Override non-empty default SpanID marshal and omitempty.
- var parentSpanId string
- if !s.ParentSpanID.IsEmpty() {
- b := make([]byte, hex.EncodedLen(spanIDSize))
- hex.Encode(b, s.ParentSpanID[:])
- parentSpanId = string(b)
- }
-
- type Alias Span
- return json.Marshal(struct {
- Alias
- ParentSpanID string `json:"parentSpanId,omitempty"`
- StartTime uint64 `json:"startTimeUnixNano,omitempty"`
- EndTime uint64 `json:"endTimeUnixNano,omitempty"`
- }{
- Alias: Alias(s),
- ParentSpanID: parentSpanId,
- StartTime: uint64(startT),
- EndTime: uint64(endT),
- })
-}
-
-// UnmarshalJSON decodes the OTLP formatted JSON contained in data into s.
-func (s *Span) UnmarshalJSON(data []byte) error {
- decoder := json.NewDecoder(bytes.NewReader(data))
-
- t, err := decoder.Token()
- if err != nil {
- return err
- }
- if t != json.Delim('{') {
- return errors.New("invalid Span type")
- }
-
- for decoder.More() {
- keyIface, err := decoder.Token()
- if err != nil {
- if errors.Is(err, io.EOF) {
- // Empty.
- return nil
- }
- return err
- }
-
- key, ok := keyIface.(string)
- if !ok {
- return fmt.Errorf("invalid Span field: %#v", keyIface)
- }
-
- switch key {
- case "traceId", "trace_id":
- err = decoder.Decode(&s.TraceID)
- case "spanId", "span_id":
- err = decoder.Decode(&s.SpanID)
- case "traceState", "trace_state":
- err = decoder.Decode(&s.TraceState)
- case "parentSpanId", "parent_span_id":
- err = decoder.Decode(&s.ParentSpanID)
- case "flags":
- err = decoder.Decode(&s.Flags)
- case "name":
- err = decoder.Decode(&s.Name)
- case "kind":
- err = decoder.Decode(&s.Kind)
- case "startTimeUnixNano", "start_time_unix_nano":
- var val protoUint64
- err = decoder.Decode(&val)
- s.StartTime = time.Unix(0, int64(val.Uint64()))
- case "endTimeUnixNano", "end_time_unix_nano":
- var val protoUint64
- err = decoder.Decode(&val)
- s.EndTime = time.Unix(0, int64(val.Uint64()))
- case "attributes":
- err = decoder.Decode(&s.Attrs)
- case "droppedAttributesCount", "dropped_attributes_count":
- err = decoder.Decode(&s.DroppedAttrs)
- case "events":
- err = decoder.Decode(&s.Events)
- case "droppedEventsCount", "dropped_events_count":
- err = decoder.Decode(&s.DroppedEvents)
- case "links":
- err = decoder.Decode(&s.Links)
- case "droppedLinksCount", "dropped_links_count":
- err = decoder.Decode(&s.DroppedLinks)
- case "status":
- err = decoder.Decode(&s.Status)
- default:
- // Skip unknown.
- }
-
- if err != nil {
- return err
- }
- }
- return nil
-}
-
-// SpanFlags represents constants used to interpret the
-// Span.flags field, which is protobuf 'fixed32' type and is to
-// be used as bit-fields. Each non-zero value defined in this enum is
-// a bit-mask. To extract the bit-field, for example, use an
-// expression like:
-//
-// (span.flags & SPAN_FLAGS_TRACE_FLAGS_MASK)
-//
-// See https://www.w3.org/TR/trace-context-2/#trace-flags for the flag definitions.
-//
-// Note that Span flags were introduced in version 1.1 of the
-// OpenTelemetry protocol. Older Span producers do not set this
-// field, consequently consumers should not rely on the absence of a
-// particular flag bit to indicate the presence of a particular feature.
-type SpanFlags int32
-
-const (
- // Bits 0-7 are used for trace flags.
- SpanFlagsTraceFlagsMask SpanFlags = 255
- // Bits 8 and 9 are used to indicate that the parent span or link span is remote.
- // Bit 8 (`HAS_IS_REMOTE`) indicates whether the value is known.
- // Bit 9 (`IS_REMOTE`) indicates whether the span or link is remote.
- SpanFlagsContextHasIsRemoteMask SpanFlags = 256
- // SpanFlagsContextHasIsRemoteMask indicates the Span is remote.
- SpanFlagsContextIsRemoteMask SpanFlags = 512
-)
-
-// SpanKind is the type of span. Can be used to specify additional relationships between spans
-// in addition to a parent/child relationship.
-type SpanKind int32
-
-const (
- // Indicates that the span represents an internal operation within an application,
- // as opposed to an operation happening at the boundaries. Default value.
- SpanKindInternal SpanKind = 1
- // Indicates that the span covers server-side handling of an RPC or other
- // remote network request.
- SpanKindServer SpanKind = 2
- // Indicates that the span describes a request to some remote service.
- SpanKindClient SpanKind = 3
- // Indicates that the span describes a producer sending a message to a broker.
- // Unlike CLIENT and SERVER, there is often no direct critical path latency relationship
- // between producer and consumer spans. A PRODUCER span ends when the message was accepted
- // by the broker while the logical processing of the message might span a much longer time.
- SpanKindProducer SpanKind = 4
- // Indicates that the span describes consumer receiving a message from a broker.
- // Like the PRODUCER kind, there is often no direct critical path latency relationship
- // between producer and consumer spans.
- SpanKindConsumer SpanKind = 5
-)
-
-// Event is a time-stamped annotation of the span, consisting of user-supplied
-// text description and key-value pairs.
-type SpanEvent struct {
- // time_unix_nano is the time the event occurred.
- Time time.Time `json:"timeUnixNano,omitempty"`
- // name of the event.
- // This field is semantically required to be set to non-empty string.
- Name string `json:"name,omitempty"`
- // attributes is a collection of attribute key/value pairs on the event.
- // Attribute keys MUST be unique (it is not allowed to have more than one
- // attribute with the same key).
- Attrs []Attr `json:"attributes,omitempty"`
- // dropped_attributes_count is the number of dropped attributes. If the value is 0,
- // then no attributes were dropped.
- DroppedAttrs uint32 `json:"droppedAttributesCount,omitempty"`
-}
-
-// MarshalJSON encodes e into OTLP formatted JSON.
-func (e SpanEvent) MarshalJSON() ([]byte, error) {
- t := e.Time.UnixNano()
- if e.Time.IsZero() || t < 0 {
- t = 0
- }
-
- type Alias SpanEvent
- return json.Marshal(struct {
- Alias
- Time uint64 `json:"timeUnixNano,omitempty"`
- }{
- Alias: Alias(e),
- Time: uint64(t),
- })
-}
-
-// UnmarshalJSON decodes the OTLP formatted JSON contained in data into se.
-func (se *SpanEvent) UnmarshalJSON(data []byte) error {
- decoder := json.NewDecoder(bytes.NewReader(data))
-
- t, err := decoder.Token()
- if err != nil {
- return err
- }
- if t != json.Delim('{') {
- return errors.New("invalid SpanEvent type")
- }
-
- for decoder.More() {
- keyIface, err := decoder.Token()
- if err != nil {
- if errors.Is(err, io.EOF) {
- // Empty.
- return nil
- }
- return err
- }
-
- key, ok := keyIface.(string)
- if !ok {
- return fmt.Errorf("invalid SpanEvent field: %#v", keyIface)
- }
-
- switch key {
- case "timeUnixNano", "time_unix_nano":
- var val protoUint64
- err = decoder.Decode(&val)
- se.Time = time.Unix(0, int64(val.Uint64()))
- case "name":
- err = decoder.Decode(&se.Name)
- case "attributes":
- err = decoder.Decode(&se.Attrs)
- case "droppedAttributesCount", "dropped_attributes_count":
- err = decoder.Decode(&se.DroppedAttrs)
- default:
- // Skip unknown.
- }
-
- if err != nil {
- return err
- }
- }
- return nil
-}
-
-// A pointer from the current span to another span in the same trace or in a
-// different trace. For example, this can be used in batching operations,
-// where a single batch handler processes multiple requests from different
-// traces or when the handler receives a request from a different project.
-type SpanLink struct {
- // A unique identifier of a trace that this linked span is part of. The ID is a
- // 16-byte array.
- TraceID TraceID `json:"traceId,omitempty"`
- // A unique identifier for the linked span. The ID is an 8-byte array.
- SpanID SpanID `json:"spanId,omitempty"`
- // The trace_state associated with the link.
- TraceState string `json:"traceState,omitempty"`
- // attributes is a collection of attribute key/value pairs on the link.
- // Attribute keys MUST be unique (it is not allowed to have more than one
- // attribute with the same key).
- Attrs []Attr `json:"attributes,omitempty"`
- // dropped_attributes_count is the number of dropped attributes. If the value is 0,
- // then no attributes were dropped.
- DroppedAttrs uint32 `json:"droppedAttributesCount,omitempty"`
- // Flags, a bit field.
- //
- // Bits 0-7 (8 least significant bits) are the trace flags as defined in W3C Trace
- // Context specification. To read the 8-bit W3C trace flag, use
- // `flags & SPAN_FLAGS_TRACE_FLAGS_MASK`.
- //
- // See https://www.w3.org/TR/trace-context-2/#trace-flags for the flag definitions.
- //
- // Bits 8 and 9 represent the 3 states of whether the link is remote.
- // The states are (unknown, is not remote, is remote).
- // To read whether the value is known, use `(flags & SPAN_FLAGS_CONTEXT_HAS_IS_REMOTE_MASK) != 0`.
- // To read whether the link is remote, use `(flags & SPAN_FLAGS_CONTEXT_IS_REMOTE_MASK) != 0`.
- //
- // Readers MUST NOT assume that bits 10-31 (22 most significant bits) will be zero.
- // When creating new spans, bits 10-31 (most-significant 22-bits) MUST be zero.
- //
- // [Optional].
- Flags uint32 `json:"flags,omitempty"`
-}
-
-// UnmarshalJSON decodes the OTLP formatted JSON contained in data into sl.
-func (sl *SpanLink) UnmarshalJSON(data []byte) error {
- decoder := json.NewDecoder(bytes.NewReader(data))
-
- t, err := decoder.Token()
- if err != nil {
- return err
- }
- if t != json.Delim('{') {
- return errors.New("invalid SpanLink type")
- }
-
- for decoder.More() {
- keyIface, err := decoder.Token()
- if err != nil {
- if errors.Is(err, io.EOF) {
- // Empty.
- return nil
- }
- return err
- }
-
- key, ok := keyIface.(string)
- if !ok {
- return fmt.Errorf("invalid SpanLink field: %#v", keyIface)
- }
-
- switch key {
- case "traceId", "trace_id":
- err = decoder.Decode(&sl.TraceID)
- case "spanId", "span_id":
- err = decoder.Decode(&sl.SpanID)
- case "traceState", "trace_state":
- err = decoder.Decode(&sl.TraceState)
- case "attributes":
- err = decoder.Decode(&sl.Attrs)
- case "droppedAttributesCount", "dropped_attributes_count":
- err = decoder.Decode(&sl.DroppedAttrs)
- case "flags":
- err = decoder.Decode(&sl.Flags)
- default:
- // Skip unknown.
- }
-
- if err != nil {
- return err
- }
- }
- return nil
-}
diff --git a/vendor/go.opentelemetry.io/auto/sdk/internal/telemetry/status.go b/vendor/go.opentelemetry.io/auto/sdk/internal/telemetry/status.go
deleted file mode 100644
index 1217776ea..000000000
--- a/vendor/go.opentelemetry.io/auto/sdk/internal/telemetry/status.go
+++ /dev/null
@@ -1,40 +0,0 @@
-// Copyright The OpenTelemetry Authors
-// SPDX-License-Identifier: Apache-2.0
-
-package telemetry
-
-// For the semantics of status codes see
-// https://github.com/open-telemetry/opentelemetry-specification/blob/main/specification/trace/api.md#set-status
-type StatusCode int32
-
-const (
- // The default status.
- StatusCodeUnset StatusCode = 0
- // The Span has been validated by an Application developer or Operator to
- // have completed successfully.
- StatusCodeOK StatusCode = 1
- // The Span contains an error.
- StatusCodeError StatusCode = 2
-)
-
-var statusCodeStrings = []string{
- "Unset",
- "OK",
- "Error",
-}
-
-func (s StatusCode) String() string {
- if s >= 0 && int(s) < len(statusCodeStrings) {
- return statusCodeStrings[s]
- }
- return "<unknown telemetry.StatusCode>"
-}
-
-// The Status type defines a logical error model that is suitable for different
-// programming environments, including REST APIs and RPC APIs.
-type Status struct {
- // A developer-facing human readable error message.
- Message string `json:"message,omitempty"`
- // The status code.
- Code StatusCode `json:"code,omitempty"`
-}
diff --git a/vendor/go.opentelemetry.io/auto/sdk/internal/telemetry/traces.go b/vendor/go.opentelemetry.io/auto/sdk/internal/telemetry/traces.go
deleted file mode 100644
index 69a348f0f..000000000
--- a/vendor/go.opentelemetry.io/auto/sdk/internal/telemetry/traces.go
+++ /dev/null
@@ -1,189 +0,0 @@
-// Copyright The OpenTelemetry Authors
-// SPDX-License-Identifier: Apache-2.0
-
-package telemetry
-
-import (
- "bytes"
- "encoding/json"
- "errors"
- "fmt"
- "io"
-)
-
-// Traces represents the traces data that can be stored in a persistent storage,
-// OR can be embedded by other protocols that transfer OTLP traces data but do
-// not implement the OTLP protocol.
-//
-// The main difference between this message and collector protocol is that
-// in this message there will not be any "control" or "metadata" specific to
-// OTLP protocol.
-//
-// When new fields are added into this message, the OTLP request MUST be updated
-// as well.
-type Traces struct {
- // An array of ResourceSpans.
- // For data coming from a single resource this array will typically contain
- // one element. Intermediary nodes that receive data from multiple origins
- // typically batch the data before forwarding further and in that case this
- // array will contain multiple elements.
- ResourceSpans []*ResourceSpans `json:"resourceSpans,omitempty"`
-}
-
-// UnmarshalJSON decodes the OTLP formatted JSON contained in data into td.
-func (td *Traces) UnmarshalJSON(data []byte) error {
- decoder := json.NewDecoder(bytes.NewReader(data))
-
- t, err := decoder.Token()
- if err != nil {
- return err
- }
- if t != json.Delim('{') {
- return errors.New("invalid TracesData type")
- }
-
- for decoder.More() {
- keyIface, err := decoder.Token()
- if err != nil {
- if errors.Is(err, io.EOF) {
- // Empty.
- return nil
- }
- return err
- }
-
- key, ok := keyIface.(string)
- if !ok {
- return fmt.Errorf("invalid TracesData field: %#v", keyIface)
- }
-
- switch key {
- case "resourceSpans", "resource_spans":
- err = decoder.Decode(&td.ResourceSpans)
- default:
- // Skip unknown.
- }
-
- if err != nil {
- return err
- }
- }
- return nil
-}
-
-// A collection of ScopeSpans from a Resource.
-type ResourceSpans struct {
- // The resource for the spans in this message.
- // If this field is not set then no resource info is known.
- Resource Resource `json:"resource"`
- // A list of ScopeSpans that originate from a resource.
- ScopeSpans []*ScopeSpans `json:"scopeSpans,omitempty"`
- // This schema_url applies to the data in the "resource" field. It does not apply
- // to the data in the "scope_spans" field which have their own schema_url field.
- SchemaURL string `json:"schemaUrl,omitempty"`
-}
-
-// UnmarshalJSON decodes the OTLP formatted JSON contained in data into rs.
-func (rs *ResourceSpans) UnmarshalJSON(data []byte) error {
- decoder := json.NewDecoder(bytes.NewReader(data))
-
- t, err := decoder.Token()
- if err != nil {
- return err
- }
- if t != json.Delim('{') {
- return errors.New("invalid ResourceSpans type")
- }
-
- for decoder.More() {
- keyIface, err := decoder.Token()
- if err != nil {
- if errors.Is(err, io.EOF) {
- // Empty.
- return nil
- }
- return err
- }
-
- key, ok := keyIface.(string)
- if !ok {
- return fmt.Errorf("invalid ResourceSpans field: %#v", keyIface)
- }
-
- switch key {
- case "resource":
- err = decoder.Decode(&rs.Resource)
- case "scopeSpans", "scope_spans":
- err = decoder.Decode(&rs.ScopeSpans)
- case "schemaUrl", "schema_url":
- err = decoder.Decode(&rs.SchemaURL)
- default:
- // Skip unknown.
- }
-
- if err != nil {
- return err
- }
- }
- return nil
-}
-
-// A collection of Spans produced by an InstrumentationScope.
-type ScopeSpans struct {
- // The instrumentation scope information for the spans in this message.
- // Semantically when InstrumentationScope isn't set, it is equivalent with
- // an empty instrumentation scope name (unknown).
- Scope *Scope `json:"scope"`
- // A list of Spans that originate from an instrumentation scope.
- Spans []*Span `json:"spans,omitempty"`
- // The Schema URL, if known. This is the identifier of the Schema that the span data
- // is recorded in. To learn more about Schema URL see
- // https://opentelemetry.io/docs/specs/otel/schemas/#schema-url
- // This schema_url applies to all spans and span events in the "spans" field.
- SchemaURL string `json:"schemaUrl,omitempty"`
-}
-
-// UnmarshalJSON decodes the OTLP formatted JSON contained in data into ss.
-func (ss *ScopeSpans) UnmarshalJSON(data []byte) error {
- decoder := json.NewDecoder(bytes.NewReader(data))
-
- t, err := decoder.Token()
- if err != nil {
- return err
- }
- if t != json.Delim('{') {
- return errors.New("invalid ScopeSpans type")
- }
-
- for decoder.More() {
- keyIface, err := decoder.Token()
- if err != nil {
- if errors.Is(err, io.EOF) {
- // Empty.
- return nil
- }
- return err
- }
-
- key, ok := keyIface.(string)
- if !ok {
- return fmt.Errorf("invalid ScopeSpans field: %#v", keyIface)
- }
-
- switch key {
- case "scope":
- err = decoder.Decode(&ss.Scope)
- case "spans":
- err = decoder.Decode(&ss.Spans)
- case "schemaUrl", "schema_url":
- err = decoder.Decode(&ss.SchemaURL)
- default:
- // Skip unknown.
- }
-
- if err != nil {
- return err
- }
- }
- return nil
-}
diff --git a/vendor/go.opentelemetry.io/auto/sdk/internal/telemetry/value.go b/vendor/go.opentelemetry.io/auto/sdk/internal/telemetry/value.go
deleted file mode 100644
index 0dd01b063..000000000
--- a/vendor/go.opentelemetry.io/auto/sdk/internal/telemetry/value.go
+++ /dev/null
@@ -1,452 +0,0 @@
-// Copyright The OpenTelemetry Authors
-// SPDX-License-Identifier: Apache-2.0
-
-//go:generate stringer -type=ValueKind -trimprefix=ValueKind
-
-package telemetry
-
-import (
- "bytes"
- "cmp"
- "encoding/base64"
- "encoding/json"
- "errors"
- "fmt"
- "io"
- "math"
- "slices"
- "strconv"
- "unsafe"
-)
-
-// A Value represents a structured value.
-// A zero value is valid and represents an empty value.
-type Value struct {
- // Ensure forward compatibility by explicitly making this not comparable.
- noCmp [0]func() //nolint: unused // This is indeed used.
-
- // num holds the value for Int64, Float64, and Bool. It holds the length
- // for String, Bytes, Slice, Map.
- num uint64
- // any holds either the KindBool, KindInt64, KindFloat64, stringptr,
- // bytesptr, sliceptr, or mapptr. If KindBool, KindInt64, or KindFloat64
- // then the value of Value is in num as described above. Otherwise, it
- // contains the value wrapped in the appropriate type.
- any any
-}
-
-type (
- // sliceptr represents a value in Value.any for KindString Values.
- stringptr *byte
- // bytesptr represents a value in Value.any for KindBytes Values.
- bytesptr *byte
- // sliceptr represents a value in Value.any for KindSlice Values.
- sliceptr *Value
- // mapptr represents a value in Value.any for KindMap Values.
- mapptr *Attr
-)
-
-// ValueKind is the kind of a [Value].
-type ValueKind int
-
-// ValueKind values.
-const (
- ValueKindEmpty ValueKind = iota
- ValueKindBool
- ValueKindFloat64
- ValueKindInt64
- ValueKindString
- ValueKindBytes
- ValueKindSlice
- ValueKindMap
-)
-
-var valueKindStrings = []string{
- "Empty",
- "Bool",
- "Float64",
- "Int64",
- "String",
- "Bytes",
- "Slice",
- "Map",
-}
-
-func (k ValueKind) String() string {
- if k >= 0 && int(k) < len(valueKindStrings) {
- return valueKindStrings[k]
- }
- return "<unknown telemetry.ValueKind>"
-}
-
-// StringValue returns a new [Value] for a string.
-func StringValue(v string) Value {
- return Value{
- num: uint64(len(v)),
- any: stringptr(unsafe.StringData(v)),
- }
-}
-
-// IntValue returns a [Value] for an int.
-func IntValue(v int) Value { return Int64Value(int64(v)) }
-
-// Int64Value returns a [Value] for an int64.
-func Int64Value(v int64) Value {
- return Value{num: uint64(v), any: ValueKindInt64}
-}
-
-// Float64Value returns a [Value] for a float64.
-func Float64Value(v float64) Value {
- return Value{num: math.Float64bits(v), any: ValueKindFloat64}
-}
-
-// BoolValue returns a [Value] for a bool.
-func BoolValue(v bool) Value { //nolint:revive // Not a control flag.
- var n uint64
- if v {
- n = 1
- }
- return Value{num: n, any: ValueKindBool}
-}
-
-// BytesValue returns a [Value] for a byte slice. The passed slice must not be
-// changed after it is passed.
-func BytesValue(v []byte) Value {
- return Value{
- num: uint64(len(v)),
- any: bytesptr(unsafe.SliceData(v)),
- }
-}
-
-// SliceValue returns a [Value] for a slice of [Value]. The passed slice must
-// not be changed after it is passed.
-func SliceValue(vs ...Value) Value {
- return Value{
- num: uint64(len(vs)),
- any: sliceptr(unsafe.SliceData(vs)),
- }
-}
-
-// MapValue returns a new [Value] for a slice of key-value pairs. The passed
-// slice must not be changed after it is passed.
-func MapValue(kvs ...Attr) Value {
- return Value{
- num: uint64(len(kvs)),
- any: mapptr(unsafe.SliceData(kvs)),
- }
-}
-
-// AsString returns the value held by v as a string.
-func (v Value) AsString() string {
- if sp, ok := v.any.(stringptr); ok {
- return unsafe.String(sp, v.num)
- }
- // TODO: error handle
- return ""
-}
-
-// asString returns the value held by v as a string. It will panic if the Value
-// is not KindString.
-func (v Value) asString() string {
- return unsafe.String(v.any.(stringptr), v.num)
-}
-
-// AsInt64 returns the value held by v as an int64.
-func (v Value) AsInt64() int64 {
- if v.Kind() != ValueKindInt64 {
- // TODO: error handle
- return 0
- }
- return v.asInt64()
-}
-
-// asInt64 returns the value held by v as an int64. If v is not of KindInt64,
-// this will return garbage.
-func (v Value) asInt64() int64 {
- // Assumes v.num was a valid int64 (overflow not checked).
- return int64(v.num) // nolint: gosec
-}
-
-// AsBool returns the value held by v as a bool.
-func (v Value) AsBool() bool {
- if v.Kind() != ValueKindBool {
- // TODO: error handle
- return false
- }
- return v.asBool()
-}
-
-// asBool returns the value held by v as a bool. If v is not of KindBool, this
-// will return garbage.
-func (v Value) asBool() bool { return v.num == 1 }
-
-// AsFloat64 returns the value held by v as a float64.
-func (v Value) AsFloat64() float64 {
- if v.Kind() != ValueKindFloat64 {
- // TODO: error handle
- return 0
- }
- return v.asFloat64()
-}
-
-// asFloat64 returns the value held by v as a float64. If v is not of
-// KindFloat64, this will return garbage.
-func (v Value) asFloat64() float64 { return math.Float64frombits(v.num) }
-
-// AsBytes returns the value held by v as a []byte.
-func (v Value) AsBytes() []byte {
- if sp, ok := v.any.(bytesptr); ok {
- return unsafe.Slice((*byte)(sp), v.num)
- }
- // TODO: error handle
- return nil
-}
-
-// asBytes returns the value held by v as a []byte. It will panic if the Value
-// is not KindBytes.
-func (v Value) asBytes() []byte {
- return unsafe.Slice((*byte)(v.any.(bytesptr)), v.num)
-}
-
-// AsSlice returns the value held by v as a []Value.
-func (v Value) AsSlice() []Value {
- if sp, ok := v.any.(sliceptr); ok {
- return unsafe.Slice((*Value)(sp), v.num)
- }
- // TODO: error handle
- return nil
-}
-
-// asSlice returns the value held by v as a []Value. It will panic if the Value
-// is not KindSlice.
-func (v Value) asSlice() []Value {
- return unsafe.Slice((*Value)(v.any.(sliceptr)), v.num)
-}
-
-// AsMap returns the value held by v as a []Attr.
-func (v Value) AsMap() []Attr {
- if sp, ok := v.any.(mapptr); ok {
- return unsafe.Slice((*Attr)(sp), v.num)
- }
- // TODO: error handle
- return nil
-}
-
-// asMap returns the value held by v as a []Attr. It will panic if the
-// Value is not KindMap.
-func (v Value) asMap() []Attr {
- return unsafe.Slice((*Attr)(v.any.(mapptr)), v.num)
-}
-
-// Kind returns the Kind of v.
-func (v Value) Kind() ValueKind {
- switch x := v.any.(type) {
- case ValueKind:
- return x
- case stringptr:
- return ValueKindString
- case bytesptr:
- return ValueKindBytes
- case sliceptr:
- return ValueKindSlice
- case mapptr:
- return ValueKindMap
- default:
- return ValueKindEmpty
- }
-}
-
-// Empty returns if v does not hold any value.
-func (v Value) Empty() bool { return v.Kind() == ValueKindEmpty }
-
-// Equal returns if v is equal to w.
-func (v Value) Equal(w Value) bool {
- k1 := v.Kind()
- k2 := w.Kind()
- if k1 != k2 {
- return false
- }
- switch k1 {
- case ValueKindInt64, ValueKindBool:
- return v.num == w.num
- case ValueKindString:
- return v.asString() == w.asString()
- case ValueKindFloat64:
- return v.asFloat64() == w.asFloat64()
- case ValueKindSlice:
- return slices.EqualFunc(v.asSlice(), w.asSlice(), Value.Equal)
- case ValueKindMap:
- sv := sortMap(v.asMap())
- sw := sortMap(w.asMap())
- return slices.EqualFunc(sv, sw, Attr.Equal)
- case ValueKindBytes:
- return bytes.Equal(v.asBytes(), w.asBytes())
- case ValueKindEmpty:
- return true
- default:
- // TODO: error handle
- return false
- }
-}
-
-func sortMap(m []Attr) []Attr {
- sm := make([]Attr, len(m))
- copy(sm, m)
- slices.SortFunc(sm, func(a, b Attr) int {
- return cmp.Compare(a.Key, b.Key)
- })
-
- return sm
-}
-
-// String returns Value's value as a string, formatted like [fmt.Sprint].
-//
-// The returned string is meant for debugging;
-// the string representation is not stable.
-func (v Value) String() string {
- switch v.Kind() {
- case ValueKindString:
- return v.asString()
- case ValueKindInt64:
- // Assumes v.num was a valid int64 (overflow not checked).
- return strconv.FormatInt(int64(v.num), 10) // nolint: gosec
- case ValueKindFloat64:
- return strconv.FormatFloat(v.asFloat64(), 'g', -1, 64)
- case ValueKindBool:
- return strconv.FormatBool(v.asBool())
- case ValueKindBytes:
- return fmt.Sprint(v.asBytes())
- case ValueKindMap:
- return fmt.Sprint(v.asMap())
- case ValueKindSlice:
- return fmt.Sprint(v.asSlice())
- case ValueKindEmpty:
- return "<nil>"
- default:
- // Try to handle this as gracefully as possible.
- //
- // Don't panic here. The goal here is to have developers find this
- // first if a slog.Kind is is not handled. It is
- // preferable to have user's open issue asking why their attributes
- // have a "unhandled: " prefix than say that their code is panicking.
- return fmt.Sprintf("<unhandled telemetry.ValueKind: %s>", v.Kind())
- }
-}
-
-// MarshalJSON encodes v into OTLP formatted JSON.
-func (v *Value) MarshalJSON() ([]byte, error) {
- switch v.Kind() {
- case ValueKindString:
- return json.Marshal(struct {
- Value string `json:"stringValue"`
- }{v.asString()})
- case ValueKindInt64:
- return json.Marshal(struct {
- Value string `json:"intValue"`
- }{strconv.FormatInt(int64(v.num), 10)})
- case ValueKindFloat64:
- return json.Marshal(struct {
- Value float64 `json:"doubleValue"`
- }{v.asFloat64()})
- case ValueKindBool:
- return json.Marshal(struct {
- Value bool `json:"boolValue"`
- }{v.asBool()})
- case ValueKindBytes:
- return json.Marshal(struct {
- Value []byte `json:"bytesValue"`
- }{v.asBytes()})
- case ValueKindMap:
- return json.Marshal(struct {
- Value struct {
- Values []Attr `json:"values"`
- } `json:"kvlistValue"`
- }{struct {
- Values []Attr `json:"values"`
- }{v.asMap()}})
- case ValueKindSlice:
- return json.Marshal(struct {
- Value struct {
- Values []Value `json:"values"`
- } `json:"arrayValue"`
- }{struct {
- Values []Value `json:"values"`
- }{v.asSlice()}})
- case ValueKindEmpty:
- return nil, nil
- default:
- return nil, fmt.Errorf("unknown Value kind: %s", v.Kind().String())
- }
-}
-
-// UnmarshalJSON decodes the OTLP formatted JSON contained in data into v.
-func (v *Value) UnmarshalJSON(data []byte) error {
- decoder := json.NewDecoder(bytes.NewReader(data))
-
- t, err := decoder.Token()
- if err != nil {
- return err
- }
- if t != json.Delim('{') {
- return errors.New("invalid Value type")
- }
-
- for decoder.More() {
- keyIface, err := decoder.Token()
- if err != nil {
- if errors.Is(err, io.EOF) {
- // Empty.
- return nil
- }
- return err
- }
-
- key, ok := keyIface.(string)
- if !ok {
- return fmt.Errorf("invalid Value key: %#v", keyIface)
- }
-
- switch key {
- case "stringValue", "string_value":
- var val string
- err = decoder.Decode(&val)
- *v = StringValue(val)
- case "boolValue", "bool_value":
- var val bool
- err = decoder.Decode(&val)
- *v = BoolValue(val)
- case "intValue", "int_value":
- var val protoInt64
- err = decoder.Decode(&val)
- *v = Int64Value(val.Int64())
- case "doubleValue", "double_value":
- var val float64
- err = decoder.Decode(&val)
- *v = Float64Value(val)
- case "bytesValue", "bytes_value":
- var val64 string
- if err := decoder.Decode(&val64); err != nil {
- return err
- }
- var val []byte
- val, err = base64.StdEncoding.DecodeString(val64)
- *v = BytesValue(val)
- case "arrayValue", "array_value":
- var val struct{ Values []Value }
- err = decoder.Decode(&val)
- *v = SliceValue(val.Values...)
- case "kvlistValue", "kvlist_value":
- var val struct{ Values []Attr }
- err = decoder.Decode(&val)
- *v = MapValue(val.Values...)
- default:
- // Skip unknown.
- continue
- }
- // Use first valid. Ignore the rest.
- return err
- }
-
- // Only unknown fields. Return nil without unmarshaling any value.
- return nil
-}
diff --git a/vendor/go.opentelemetry.io/auto/sdk/limit.go b/vendor/go.opentelemetry.io/auto/sdk/limit.go
deleted file mode 100644
index 86babf1a8..000000000
--- a/vendor/go.opentelemetry.io/auto/sdk/limit.go
+++ /dev/null
@@ -1,94 +0,0 @@
-// Copyright The OpenTelemetry Authors
-// SPDX-License-Identifier: Apache-2.0
-
-package sdk
-
-import (
- "log/slog"
- "os"
- "strconv"
-)
-
-// maxSpan are the span limits resolved during startup.
-var maxSpan = newSpanLimits()
-
-type spanLimits struct {
- // Attrs is the number of allowed attributes for a span.
- //
- // This is resolved from the environment variable value for the
- // OTEL_SPAN_ATTRIBUTE_COUNT_LIMIT key if it exists. Otherwise, the
- // environment variable value for OTEL_ATTRIBUTE_COUNT_LIMIT, or 128 if
- // that is not set, is used.
- Attrs int
- // AttrValueLen is the maximum attribute value length allowed for a span.
- //
- // This is resolved from the environment variable value for the
- // OTEL_SPAN_ATTRIBUTE_VALUE_LENGTH_LIMIT key if it exists. Otherwise, the
- // environment variable value for OTEL_ATTRIBUTE_VALUE_LENGTH_LIMIT, or -1
- // if that is not set, is used.
- AttrValueLen int
- // Events is the number of allowed events for a span.
- //
- // This is resolved from the environment variable value for the
- // OTEL_SPAN_EVENT_COUNT_LIMIT key, or 128 is used if that is not set.
- Events int
- // EventAttrs is the number of allowed attributes for a span event.
- //
- // The is resolved from the environment variable value for the
- // OTEL_EVENT_ATTRIBUTE_COUNT_LIMIT key, or 128 is used if that is not set.
- EventAttrs int
- // Links is the number of allowed Links for a span.
- //
- // This is resolved from the environment variable value for the
- // OTEL_SPAN_LINK_COUNT_LIMIT, or 128 is used if that is not set.
- Links int
- // LinkAttrs is the number of allowed attributes for a span link.
- //
- // This is resolved from the environment variable value for the
- // OTEL_LINK_ATTRIBUTE_COUNT_LIMIT, or 128 is used if that is not set.
- LinkAttrs int
-}
-
-func newSpanLimits() spanLimits {
- return spanLimits{
- Attrs: firstEnv(
- 128,
- "OTEL_SPAN_ATTRIBUTE_COUNT_LIMIT",
- "OTEL_ATTRIBUTE_COUNT_LIMIT",
- ),
- AttrValueLen: firstEnv(
- -1, // Unlimited.
- "OTEL_SPAN_ATTRIBUTE_VALUE_LENGTH_LIMIT",
- "OTEL_ATTRIBUTE_VALUE_LENGTH_LIMIT",
- ),
- Events: firstEnv(128, "OTEL_SPAN_EVENT_COUNT_LIMIT"),
- EventAttrs: firstEnv(128, "OTEL_EVENT_ATTRIBUTE_COUNT_LIMIT"),
- Links: firstEnv(128, "OTEL_SPAN_LINK_COUNT_LIMIT"),
- LinkAttrs: firstEnv(128, "OTEL_LINK_ATTRIBUTE_COUNT_LIMIT"),
- }
-}
-
-// firstEnv returns the parsed integer value of the first matching environment
-// variable from keys. The defaultVal is returned if the value is not an
-// integer or no match is found.
-func firstEnv(defaultVal int, keys ...string) int {
- for _, key := range keys {
- strV := os.Getenv(key)
- if strV == "" {
- continue
- }
-
- v, err := strconv.Atoi(strV)
- if err == nil {
- return v
- }
- slog.Warn(
- "invalid limit environment variable",
- "error", err,
- "key", key,
- "value", strV,
- )
- }
-
- return defaultVal
-}
diff --git a/vendor/go.opentelemetry.io/auto/sdk/span.go b/vendor/go.opentelemetry.io/auto/sdk/span.go
deleted file mode 100644
index 6ebea12a9..000000000
--- a/vendor/go.opentelemetry.io/auto/sdk/span.go
+++ /dev/null
@@ -1,432 +0,0 @@
-// Copyright The OpenTelemetry Authors
-// SPDX-License-Identifier: Apache-2.0
-
-package sdk
-
-import (
- "encoding/json"
- "fmt"
- "reflect"
- "runtime"
- "strings"
- "sync"
- "sync/atomic"
- "time"
- "unicode/utf8"
-
- "go.opentelemetry.io/otel/attribute"
- "go.opentelemetry.io/otel/codes"
- semconv "go.opentelemetry.io/otel/semconv/v1.26.0"
- "go.opentelemetry.io/otel/trace"
- "go.opentelemetry.io/otel/trace/noop"
-
- "go.opentelemetry.io/auto/sdk/internal/telemetry"
-)
-
-type span struct {
- noop.Span
-
- spanContext trace.SpanContext
- sampled atomic.Bool
-
- mu sync.Mutex
- traces *telemetry.Traces
- span *telemetry.Span
-}
-
-func (s *span) SpanContext() trace.SpanContext {
- if s == nil {
- return trace.SpanContext{}
- }
- // s.spanContext is immutable, do not acquire lock s.mu.
- return s.spanContext
-}
-
-func (s *span) IsRecording() bool {
- if s == nil {
- return false
- }
-
- return s.sampled.Load()
-}
-
-func (s *span) SetStatus(c codes.Code, msg string) {
- if s == nil || !s.sampled.Load() {
- return
- }
-
- s.mu.Lock()
- defer s.mu.Unlock()
-
- if s.span.Status == nil {
- s.span.Status = new(telemetry.Status)
- }
-
- s.span.Status.Message = msg
-
- switch c {
- case codes.Unset:
- s.span.Status.Code = telemetry.StatusCodeUnset
- case codes.Error:
- s.span.Status.Code = telemetry.StatusCodeError
- case codes.Ok:
- s.span.Status.Code = telemetry.StatusCodeOK
- }
-}
-
-func (s *span) SetAttributes(attrs ...attribute.KeyValue) {
- if s == nil || !s.sampled.Load() {
- return
- }
-
- s.mu.Lock()
- defer s.mu.Unlock()
-
- limit := maxSpan.Attrs
- if limit == 0 {
- // No attributes allowed.
- s.span.DroppedAttrs += uint32(len(attrs))
- return
- }
-
- m := make(map[string]int)
- for i, a := range s.span.Attrs {
- m[a.Key] = i
- }
-
- for _, a := range attrs {
- val := convAttrValue(a.Value)
- if val.Empty() {
- s.span.DroppedAttrs++
- continue
- }
-
- if idx, ok := m[string(a.Key)]; ok {
- s.span.Attrs[idx] = telemetry.Attr{
- Key: string(a.Key),
- Value: val,
- }
- } else if limit < 0 || len(s.span.Attrs) < limit {
- s.span.Attrs = append(s.span.Attrs, telemetry.Attr{
- Key: string(a.Key),
- Value: val,
- })
- m[string(a.Key)] = len(s.span.Attrs) - 1
- } else {
- s.span.DroppedAttrs++
- }
- }
-}
-
-// convCappedAttrs converts up to limit attrs into a []telemetry.Attr. The
-// number of dropped attributes is also returned.
-func convCappedAttrs(limit int, attrs []attribute.KeyValue) ([]telemetry.Attr, uint32) {
- if limit == 0 {
- return nil, uint32(len(attrs))
- }
-
- if limit < 0 {
- // Unlimited.
- return convAttrs(attrs), 0
- }
-
- limit = min(len(attrs), limit)
- return convAttrs(attrs[:limit]), uint32(len(attrs) - limit)
-}
-
-func convAttrs(attrs []attribute.KeyValue) []telemetry.Attr {
- if len(attrs) == 0 {
- // Avoid allocations if not necessary.
- return nil
- }
-
- out := make([]telemetry.Attr, 0, len(attrs))
- for _, attr := range attrs {
- key := string(attr.Key)
- val := convAttrValue(attr.Value)
- if val.Empty() {
- continue
- }
- out = append(out, telemetry.Attr{Key: key, Value: val})
- }
- return out
-}
-
-func convAttrValue(value attribute.Value) telemetry.Value {
- switch value.Type() {
- case attribute.BOOL:
- return telemetry.BoolValue(value.AsBool())
- case attribute.INT64:
- return telemetry.Int64Value(value.AsInt64())
- case attribute.FLOAT64:
- return telemetry.Float64Value(value.AsFloat64())
- case attribute.STRING:
- v := truncate(maxSpan.AttrValueLen, value.AsString())
- return telemetry.StringValue(v)
- case attribute.BOOLSLICE:
- slice := value.AsBoolSlice()
- out := make([]telemetry.Value, 0, len(slice))
- for _, v := range slice {
- out = append(out, telemetry.BoolValue(v))
- }
- return telemetry.SliceValue(out...)
- case attribute.INT64SLICE:
- slice := value.AsInt64Slice()
- out := make([]telemetry.Value, 0, len(slice))
- for _, v := range slice {
- out = append(out, telemetry.Int64Value(v))
- }
- return telemetry.SliceValue(out...)
- case attribute.FLOAT64SLICE:
- slice := value.AsFloat64Slice()
- out := make([]telemetry.Value, 0, len(slice))
- for _, v := range slice {
- out = append(out, telemetry.Float64Value(v))
- }
- return telemetry.SliceValue(out...)
- case attribute.STRINGSLICE:
- slice := value.AsStringSlice()
- out := make([]telemetry.Value, 0, len(slice))
- for _, v := range slice {
- v = truncate(maxSpan.AttrValueLen, v)
- out = append(out, telemetry.StringValue(v))
- }
- return telemetry.SliceValue(out...)
- }
- return telemetry.Value{}
-}
-
-// truncate returns a truncated version of s such that it contains less than
-// the limit number of characters. Truncation is applied by returning the limit
-// number of valid characters contained in s.
-//
-// If limit is negative, it returns the original string.
-//
-// UTF-8 is supported. When truncating, all invalid characters are dropped
-// before applying truncation.
-//
-// If s already contains less than the limit number of bytes, it is returned
-// unchanged. No invalid characters are removed.
-func truncate(limit int, s string) string {
- // This prioritize performance in the following order based on the most
- // common expected use-cases.
- //
- // - Short values less than the default limit (128).
- // - Strings with valid encodings that exceed the limit.
- // - No limit.
- // - Strings with invalid encodings that exceed the limit.
- if limit < 0 || len(s) <= limit {
- return s
- }
-
- // Optimistically, assume all valid UTF-8.
- var b strings.Builder
- count := 0
- for i, c := range s {
- if c != utf8.RuneError {
- count++
- if count > limit {
- return s[:i]
- }
- continue
- }
-
- _, size := utf8.DecodeRuneInString(s[i:])
- if size == 1 {
- // Invalid encoding.
- b.Grow(len(s) - 1)
- _, _ = b.WriteString(s[:i])
- s = s[i:]
- break
- }
- }
-
- // Fast-path, no invalid input.
- if b.Cap() == 0 {
- return s
- }
-
- // Truncate while validating UTF-8.
- for i := 0; i < len(s) && count < limit; {
- c := s[i]
- if c < utf8.RuneSelf {
- // Optimization for single byte runes (common case).
- _ = b.WriteByte(c)
- i++
- count++
- continue
- }
-
- _, size := utf8.DecodeRuneInString(s[i:])
- if size == 1 {
- // We checked for all 1-byte runes above, this is a RuneError.
- i++
- continue
- }
-
- _, _ = b.WriteString(s[i : i+size])
- i += size
- count++
- }
-
- return b.String()
-}
-
-func (s *span) End(opts ...trace.SpanEndOption) {
- if s == nil || !s.sampled.Swap(false) {
- return
- }
-
- // s.end exists so the lock (s.mu) is not held while s.ended is called.
- s.ended(s.end(opts))
-}
-
-func (s *span) end(opts []trace.SpanEndOption) []byte {
- s.mu.Lock()
- defer s.mu.Unlock()
-
- cfg := trace.NewSpanEndConfig(opts...)
- if t := cfg.Timestamp(); !t.IsZero() {
- s.span.EndTime = cfg.Timestamp()
- } else {
- s.span.EndTime = time.Now()
- }
-
- b, _ := json.Marshal(s.traces) // TODO: do not ignore this error.
- return b
-}
-
-// Expected to be implemented in eBPF.
-//
-//go:noinline
-func (*span) ended(buf []byte) { ended(buf) }
-
-// ended is used for testing.
-var ended = func([]byte) {}
-
-func (s *span) RecordError(err error, opts ...trace.EventOption) {
- if s == nil || err == nil || !s.sampled.Load() {
- return
- }
-
- cfg := trace.NewEventConfig(opts...)
-
- attrs := cfg.Attributes()
- attrs = append(attrs,
- semconv.ExceptionType(typeStr(err)),
- semconv.ExceptionMessage(err.Error()),
- )
- if cfg.StackTrace() {
- buf := make([]byte, 2048)
- n := runtime.Stack(buf, false)
- attrs = append(attrs, semconv.ExceptionStacktrace(string(buf[0:n])))
- }
-
- s.mu.Lock()
- defer s.mu.Unlock()
-
- s.addEvent(semconv.ExceptionEventName, cfg.Timestamp(), attrs)
-}
-
-func typeStr(i any) string {
- t := reflect.TypeOf(i)
- if t.PkgPath() == "" && t.Name() == "" {
- // Likely a builtin type.
- return t.String()
- }
- return fmt.Sprintf("%s.%s", t.PkgPath(), t.Name())
-}
-
-func (s *span) AddEvent(name string, opts ...trace.EventOption) {
- if s == nil || !s.sampled.Load() {
- return
- }
-
- cfg := trace.NewEventConfig(opts...)
-
- s.mu.Lock()
- defer s.mu.Unlock()
-
- s.addEvent(name, cfg.Timestamp(), cfg.Attributes())
-}
-
-// addEvent adds an event with name and attrs at tStamp to the span. The span
-// lock (s.mu) needs to be held by the caller.
-func (s *span) addEvent(name string, tStamp time.Time, attrs []attribute.KeyValue) {
- limit := maxSpan.Events
-
- if limit == 0 {
- s.span.DroppedEvents++
- return
- }
-
- if limit > 0 && len(s.span.Events) == limit {
- // Drop head while avoiding allocation of more capacity.
- copy(s.span.Events[:limit-1], s.span.Events[1:])
- s.span.Events = s.span.Events[:limit-1]
- s.span.DroppedEvents++
- }
-
- e := &telemetry.SpanEvent{Time: tStamp, Name: name}
- e.Attrs, e.DroppedAttrs = convCappedAttrs(maxSpan.EventAttrs, attrs)
-
- s.span.Events = append(s.span.Events, e)
-}
-
-func (s *span) AddLink(link trace.Link) {
- if s == nil || !s.sampled.Load() {
- return
- }
-
- l := maxSpan.Links
-
- s.mu.Lock()
- defer s.mu.Unlock()
-
- if l == 0 {
- s.span.DroppedLinks++
- return
- }
-
- if l > 0 && len(s.span.Links) == l {
- // Drop head while avoiding allocation of more capacity.
- copy(s.span.Links[:l-1], s.span.Links[1:])
- s.span.Links = s.span.Links[:l-1]
- s.span.DroppedLinks++
- }
-
- s.span.Links = append(s.span.Links, convLink(link))
-}
-
-func convLinks(links []trace.Link) []*telemetry.SpanLink {
- out := make([]*telemetry.SpanLink, 0, len(links))
- for _, link := range links {
- out = append(out, convLink(link))
- }
- return out
-}
-
-func convLink(link trace.Link) *telemetry.SpanLink {
- l := &telemetry.SpanLink{
- TraceID: telemetry.TraceID(link.SpanContext.TraceID()),
- SpanID: telemetry.SpanID(link.SpanContext.SpanID()),
- TraceState: link.SpanContext.TraceState().String(),
- Flags: uint32(link.SpanContext.TraceFlags()),
- }
- l.Attrs, l.DroppedAttrs = convCappedAttrs(maxSpan.LinkAttrs, link.Attributes)
-
- return l
-}
-
-func (s *span) SetName(name string) {
- if s == nil || !s.sampled.Load() {
- return
- }
-
- s.mu.Lock()
- defer s.mu.Unlock()
-
- s.span.Name = name
-}
-
-func (*span) TracerProvider() trace.TracerProvider { return TracerProvider() }
diff --git a/vendor/go.opentelemetry.io/auto/sdk/tracer.go b/vendor/go.opentelemetry.io/auto/sdk/tracer.go
deleted file mode 100644
index cbcfabde3..000000000
--- a/vendor/go.opentelemetry.io/auto/sdk/tracer.go
+++ /dev/null
@@ -1,124 +0,0 @@
-// Copyright The OpenTelemetry Authors
-// SPDX-License-Identifier: Apache-2.0
-
-package sdk
-
-import (
- "context"
- "time"
-
- "go.opentelemetry.io/otel/trace"
- "go.opentelemetry.io/otel/trace/noop"
-
- "go.opentelemetry.io/auto/sdk/internal/telemetry"
-)
-
-type tracer struct {
- noop.Tracer
-
- name, schemaURL, version string
-}
-
-var _ trace.Tracer = tracer{}
-
-func (t tracer) Start(ctx context.Context, name string, opts ...trace.SpanStartOption) (context.Context, trace.Span) {
- var psc trace.SpanContext
- sampled := true
- span := new(span)
-
- // Ask eBPF for sampling decision and span context info.
- t.start(ctx, span, &psc, &sampled, &span.spanContext)
-
- span.sampled.Store(sampled)
-
- ctx = trace.ContextWithSpan(ctx, span)
-
- if sampled {
- // Only build traces if sampled.
- cfg := trace.NewSpanStartConfig(opts...)
- span.traces, span.span = t.traces(name, cfg, span.spanContext, psc)
- }
-
- return ctx, span
-}
-
-// Expected to be implemented in eBPF.
-//
-//go:noinline
-func (t *tracer) start(
- ctx context.Context,
- spanPtr *span,
- psc *trace.SpanContext,
- sampled *bool,
- sc *trace.SpanContext,
-) {
- start(ctx, spanPtr, psc, sampled, sc)
-}
-
-// start is used for testing.
-var start = func(context.Context, *span, *trace.SpanContext, *bool, *trace.SpanContext) {}
-
-func (t tracer) traces(name string, cfg trace.SpanConfig, sc, psc trace.SpanContext) (*telemetry.Traces, *telemetry.Span) {
- span := &telemetry.Span{
- TraceID: telemetry.TraceID(sc.TraceID()),
- SpanID: telemetry.SpanID(sc.SpanID()),
- Flags: uint32(sc.TraceFlags()),
- TraceState: sc.TraceState().String(),
- ParentSpanID: telemetry.SpanID(psc.SpanID()),
- Name: name,
- Kind: spanKind(cfg.SpanKind()),
- }
-
- span.Attrs, span.DroppedAttrs = convCappedAttrs(maxSpan.Attrs, cfg.Attributes())
-
- links := cfg.Links()
- if limit := maxSpan.Links; limit == 0 {
- span.DroppedLinks = uint32(len(links))
- } else {
- if limit > 0 {
- n := max(len(links)-limit, 0)
- span.DroppedLinks = uint32(n)
- links = links[n:]
- }
- span.Links = convLinks(links)
- }
-
- if t := cfg.Timestamp(); !t.IsZero() {
- span.StartTime = cfg.Timestamp()
- } else {
- span.StartTime = time.Now()
- }
-
- return &telemetry.Traces{
- ResourceSpans: []*telemetry.ResourceSpans{
- {
- ScopeSpans: []*telemetry.ScopeSpans{
- {
- Scope: &telemetry.Scope{
- Name: t.name,
- Version: t.version,
- },
- Spans: []*telemetry.Span{span},
- SchemaURL: t.schemaURL,
- },
- },
- },
- },
- }, span
-}
-
-func spanKind(kind trace.SpanKind) telemetry.SpanKind {
- switch kind {
- case trace.SpanKindInternal:
- return telemetry.SpanKindInternal
- case trace.SpanKindServer:
- return telemetry.SpanKindServer
- case trace.SpanKindClient:
- return telemetry.SpanKindClient
- case trace.SpanKindProducer:
- return telemetry.SpanKindProducer
- case trace.SpanKindConsumer:
- return telemetry.SpanKindConsumer
- }
- return telemetry.SpanKind(0) // undefined.
-}
diff --git a/vendor/go.opentelemetry.io/auto/sdk/tracer_provider.go b/vendor/go.opentelemetry.io/auto/sdk/tracer_provider.go
deleted file mode 100644
index dbc477a59..000000000
--- a/vendor/go.opentelemetry.io/auto/sdk/tracer_provider.go
+++ /dev/null
@@ -1,33 +0,0 @@
-// Copyright The OpenTelemetry Authors
-// SPDX-License-Identifier: Apache-2.0
-
-package sdk
-
-import (
- "go.opentelemetry.io/otel/trace"
- "go.opentelemetry.io/otel/trace/noop"
-)
-
-// TracerProvider returns an auto-instrumentable [trace.TracerProvider].
-//
-// If an [go.opentelemetry.io/auto.Instrumentation] is configured to instrument
-// the process using the returned TracerProvider, all of the telemetry it
-// produces will be processed and handled by that Instrumentation. By default,
-// if no Instrumentation instruments the TracerProvider it will not generate
-// any trace telemetry.
-func TracerProvider() trace.TracerProvider { return tracerProviderInstance }
-
-var tracerProviderInstance = new(tracerProvider)
-
-type tracerProvider struct{ noop.TracerProvider }
-
-var _ trace.TracerProvider = tracerProvider{}
-
-func (p tracerProvider) Tracer(name string, opts ...trace.TracerOption) trace.Tracer {
- cfg := trace.NewTracerConfig(opts...)
- return tracer{
- name: name,
- version: cfg.InstrumentationVersion(),
- schemaURL: cfg.SchemaURL(),
- }
-}