-
Notifications
You must be signed in to change notification settings - Fork 1.1k
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
- Loading branch information
Showing
22 changed files
with
1,734 additions
and
0 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,81 @@ | ||
| # OpenCensus Bridge | ||
|
|
||
| The OpenCensus Bridge helps facilitate the migration of an application from OpenCensus to OpenTelemetry. | ||
|
|
||
| ## Caveat about OpenCensus | ||
|
|
||
| Installing a metric or tracing bridge will cause OpenCensus telemetry to be exported by OpenTelemetry exporters. Since OpenCensus telemetry uses globals, installing a bridge will result in telemetry collection from _all_ libraries that use OpenCensus, including some you may not expect. For example ([#1928](https://github.com/open-telemetry/opentelemetry-go/issues/1928)), if a client library generates traces with OpenCensus, installing the bridge will cause those traces to be exported by OpenTelemetry. | ||
|
|
||
| ## Tracing | ||
|
|
||
| ### The Problem: Mixing OpenCensus and OpenTelemetry libraries | ||
|
|
||
| In a perfect world, one would simply migrate their entire go application --including custom instrumentation, libraries, and exporters-- from OpenCensus to OpenTelemetry all at once. In the real world, dependency constraints, third-party ownership of libraries, or other reasons may require mixing OpenCensus and OpenTelemetry libraries in a single application. | ||
|
|
||
| However, if you create the following spans in a go application: | ||
|
|
||
| ```go | ||
| ctx, ocSpan := opencensus.StartSpan(context.Background(), "OuterSpan") | ||
| defer ocSpan.End() | ||
| ctx, otSpan := opentelemetryTracer.Start(ctx, "MiddleSpan") | ||
| defer otSpan.End() | ||
| ctx, ocSpan := opencensus.StartSpan(ctx, "InnerSpan") | ||
| defer ocSpan.End() | ||
| ``` | ||
|
|
||
| OpenCensus reports (to OpenCensus exporters): | ||
|
|
||
| ``` | ||
| [--------OuterSpan------------] | ||
| [----InnerSpan------] | ||
| ``` | ||
|
|
||
| OpenTelemetry reports (to OpenTelemetry exporters): | ||
|
|
||
| ``` | ||
| [-----MiddleSpan--------] | ||
| ``` | ||
|
|
||
| Instead, I would prefer (to a single set of exporters): | ||
|
|
||
| ``` | ||
| [--------OuterSpan------------] | ||
| [-----MiddleSpan--------] | ||
| [----InnerSpan------] | ||
| ``` | ||
|
|
||
| ### The bridge solution | ||
|
|
||
| The bridge implements the OpenCensus trace API using OpenTelemetry. This would cause, for example, a span recorded with OpenCensus' `StartSpan()` method to be equivalent to recording a span using OpenTelemetry's `tracer.Start()` method. Funneling all tracing API calls to OpenTelemetry APIs results in the desired unified span hierarchy. | ||
|
|
||
| ### User Journey | ||
|
|
||
| Starting from an application using entirely OpenCensus APIs: | ||
|
|
||
| 1. Instantiate OpenTelemetry SDK and Exporters | ||
| 2. Override OpenCensus' DefaultTracer with the bridge | ||
| 3. Migrate libraries individually from OpenCensus to OpenTelemetry | ||
| 4. Remove OpenCensus exporters and configuration | ||
|
|
||
| To override OpenCensus' DefaultTracer with the bridge: | ||
|
|
||
| ```go | ||
| import ( | ||
| octrace "go.opencensus.io/trace" | ||
| "go.opentelemetry.io/otel/bridge/opencensus" | ||
| "go.opentelemetry.io/otel" | ||
| ) | ||
|
|
||
| tracer := otel.GetTracerProvider().Tracer("bridge") | ||
| octrace.DefaultTracer = opencensus.NewTracer(tracer) | ||
| ``` | ||
|
|
||
| Be sure to set the `Tracer` name to your instrumentation package name instead of `"bridge"`. | ||
|
|
||
| #### Incompatibilities | ||
|
|
||
| OpenCensus and OpenTelemetry APIs are not entirely compatible. If the bridge finds any incompatibilities, it will log them. Incompatibilities include: | ||
|
|
||
| * Custom OpenCensus Samplers specified during StartSpan are ignored. | ||
| * Links cannot be added to OpenCensus spans. | ||
| * OpenTelemetry Debug or Deferred trace flags are dropped after an OpenCensus span is created. |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,44 @@ | ||
| // Copyright The OpenTelemetry Authors | ||
| // | ||
| // 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. | ||
|
|
||
| package opencensus // import "go.opentelemetry.io/otel/bridge/opencensus" | ||
|
|
||
| import ( | ||
| octrace "go.opencensus.io/trace" | ||
|
|
||
| "go.opentelemetry.io/otel/bridge/opencensus/internal" | ||
| "go.opentelemetry.io/otel/bridge/opencensus/internal/oc2otel" | ||
| "go.opentelemetry.io/otel/bridge/opencensus/internal/otel2oc" | ||
| "go.opentelemetry.io/otel/trace" | ||
| ) | ||
|
|
||
| // NewTracer returns an implementation of the OpenCensus Tracer interface which | ||
| // uses OpenTelemetry APIs. Using this implementation of Tracer "upgrades" | ||
| // libraries that use OpenCensus to OpenTelemetry to facilitate a migration. | ||
| func NewTracer(tracer trace.Tracer) octrace.Tracer { | ||
| return internal.NewTracer(tracer) | ||
| } | ||
|
|
||
| // OTelSpanContextToOC converts from an OpenTelemetry SpanContext to an | ||
| // OpenCensus SpanContext, and handles any incompatibilities with the global | ||
| // error handler. | ||
| func OTelSpanContextToOC(sc trace.SpanContext) octrace.SpanContext { | ||
| return otel2oc.SpanContext(sc) | ||
| } | ||
|
|
||
| // OCSpanContextToOTel converts from an OpenCensus SpanContext to an | ||
| // OpenTelemetry SpanContext. | ||
| func OCSpanContextToOTel(sc octrace.SpanContext) trace.SpanContext { | ||
| return oc2otel.SpanContext(sc) | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,35 @@ | ||
| // Copyright The OpenTelemetry Authors | ||
| // | ||
| // 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. | ||
|
|
||
| // Package opencensus provides a migration bridge from OpenCensus to | ||
| // OpenTelemetry. The NewTracer function should be used to create an | ||
| // OpenCensus Tracer from an OpenTelemetry Tracer. This Tracer can be use in | ||
| // place of any existing OpenCensus Tracer and will generate OpenTelemetry | ||
| // spans for traces. These spans will be exported by the OpenTelemetry | ||
| // TracerProvider the original OpenTelemetry Tracer came from. | ||
| // | ||
| // There are known limitations to this bridge: | ||
| // | ||
| // - The AddLink method for OpenCensus Spans is not compatible with the | ||
| // OpenTelemetry Span. No link can be added to an OpenTelemetry Span once it | ||
| // is started. Any calls to this method for the OpenCensus Span will result | ||
| // in an error being sent to the OpenTelemetry default ErrorHandler. | ||
| // | ||
| // - The NewContext method of the OpenCensus Tracer cannot embed an OpenCensus | ||
| // Span in a context unless that Span was created by that Tracer. | ||
| // | ||
| // - Conversion of custom OpenCensus Samplers to OpenTelemetry is not | ||
| // implemented. An error will be sent to the OpenTelemetry default | ||
| // ErrorHandler if this is attempted. | ||
| package opencensus // import "go.opentelemetry.io/otel/bridge/opencensus" |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,19 @@ | ||
| module go.opentelemetry.io/otel/bridge/opencensus | ||
|
|
||
| go 1.17 | ||
|
|
||
| require ( | ||
| go.opencensus.io v0.22.6-0.20201102222123-380f4078db9f | ||
| go.opentelemetry.io/otel v1.9.0 | ||
| go.opentelemetry.io/otel/trace v1.9.0 | ||
| ) | ||
|
|
||
| require ( | ||
| github.com/go-logr/logr v1.2.3 // indirect | ||
| github.com/go-logr/stdr v1.2.2 // indirect | ||
| github.com/golang/groupcache v0.0.0-20190702054246-869f871628b6 // indirect | ||
| ) | ||
|
|
||
| replace go.opentelemetry.io/otel => ../.. | ||
|
|
||
| replace go.opentelemetry.io/otel/trace => ../../trace |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,58 @@ | ||
| cloud.google.com/go v0.26.0/go.mod h1:aQUYkXzVsufM+DwF1aE+0xfcU+56JwCaLick0ClmMTw= | ||
| github.com/BurntSushi/toml v0.3.1/go.mod h1:xHWCNGjB5oqiDr8zfno3MHue2Ht5sIBksp03qcyfWMU= | ||
| github.com/client9/misspell v0.3.4/go.mod h1:qj6jICC3Q7zFZvVWo7KLAzC3yx5G7kyvSDkc90ppPyw= | ||
| github.com/davecgh/go-spew v1.1.0 h1:ZDRjVQ15GmhC3fiQ8ni8+OwkZQO4DARzQgrnXU1Liz8= | ||
| github.com/davecgh/go-spew v1.1.0/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38= | ||
| github.com/go-logr/logr v1.2.2/go.mod h1:jdQByPbusPIv2/zmleS9BjJVeZ6kBagPoEUsqbVz/1A= | ||
| github.com/go-logr/logr v1.2.3 h1:2DntVwHkVopvECVRSlL5PSo9eG+cAkDCuckLubN+rq0= | ||
| github.com/go-logr/logr v1.2.3/go.mod h1:jdQByPbusPIv2/zmleS9BjJVeZ6kBagPoEUsqbVz/1A= | ||
| github.com/go-logr/stdr v1.2.2 h1:hSWxHoqTgW2S2qGc0LTAI563KZ5YKYRhT3MFKZMbjag= | ||
| github.com/go-logr/stdr v1.2.2/go.mod h1:mMo/vtBO5dYbehREoey6XUKy/eSumjCCveDpRre4VKE= | ||
| github.com/golang/glog v0.0.0-20160126235308-23def4e6c14b/go.mod h1:SBH7ygxi8pfUlaOkMMuAQtPIUF8ecWP5IEl/CR7VP2Q= | ||
| github.com/golang/groupcache v0.0.0-20190702054246-869f871628b6 h1:ZgQEtGgCBiWRM39fZuwSd1LwSqqSW0hOdXCYYDX0R3I= | ||
| github.com/golang/groupcache v0.0.0-20190702054246-869f871628b6/go.mod h1:cIg4eruTrX1D+g88fzRXU5OdNfaM+9IcxsU14FzY7Hc= | ||
| github.com/golang/mock v1.1.1/go.mod h1:oTYuIxOrZwtPieC+H1uAHpcLFnEyAGVDL/k47Jfbm0A= | ||
| github.com/golang/protobuf v1.2.0/go.mod h1:6lQm79b+lXiMfvg/cZm0SGofjICqVBUtrP5yJMmIC1U= | ||
| github.com/golang/protobuf v1.3.1/go.mod h1:6lQm79b+lXiMfvg/cZm0SGofjICqVBUtrP5yJMmIC1U= | ||
| github.com/google/go-cmp v0.3.0/go.mod h1:8QqcDgzrUqlUb/G2PQTWiueGozuR1884gddMywk6iLU= | ||
| github.com/google/go-cmp v0.5.8 h1:e6P7q2lk1O+qJJb4BtCQXlK8vWEO8V1ZeuEdJNOqZyg= | ||
| github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZbAQM= | ||
| github.com/pmezard/go-difflib v1.0.0/go.mod h1:iKH77koFhYxTK1pcRnkKkqfTogsbg7gZNVY4sRDYZ/4= | ||
| github.com/stretchr/objx v0.1.0/go.mod h1:HFkY916IF+rwdDfMAkV7OtwuqBVzrE8GR6GFx+wExME= | ||
| github.com/stretchr/testify v1.4.0/go.mod h1:j7eGeouHqKxXV5pUuKE4zz7dFj8WfuZ+81PSLYec5m4= | ||
| github.com/stretchr/testify v1.7.1 h1:5TQK59W5E3v0r2duFAb7P95B6hEeOyEnHRa8MjYSMTY= | ||
| go.opencensus.io v0.22.6-0.20201102222123-380f4078db9f h1:IUmbcoP9XyEXW+R9AbrZgDvaYVfTbISN92Y5RIV+Mx4= | ||
| go.opencensus.io v0.22.6-0.20201102222123-380f4078db9f/go.mod h1:5pWMHQbX5EPX2/62yrJeAkowc+lfs/XD7Uxpq3pI6kk= | ||
| golang.org/x/crypto v0.0.0-20190308221718-c2843e01d9a2/go.mod h1:djNgcEr1/C05ACkg1iLfiJU5Ep61QUkGW8qpdssI0+w= | ||
| golang.org/x/exp v0.0.0-20190121172915-509febef88a4/go.mod h1:CJ0aWSM057203Lf6IL+f9T1iT9GByDxfZKAQTCR3kQA= | ||
| golang.org/x/lint v0.0.0-20181026193005-c67002cb31c3/go.mod h1:UVdnD1Gm6xHRNCYTkRU2/jEulfH38KcIWyp/GAMgvoE= | ||
| golang.org/x/lint v0.0.0-20190227174305-5b3e6a55c961/go.mod h1:wehouNa3lNwaWXcvxsM5YxQ5yQlVC4a0KAMCusXpPoU= | ||
| golang.org/x/lint v0.0.0-20190313153728-d0100b6bd8b3/go.mod h1:6SW0HCj/g11FgYtHlgUYUwCkIfeOF89ocIRzGO/8vkc= | ||
| golang.org/x/net v0.0.0-20180724234803-3673e40ba225/go.mod h1:mL1N/T3taQHkDXs73rZJwtUhF3w3ftmwwsq0BUmARs4= | ||
| golang.org/x/net v0.0.0-20180826012351-8a410e7b638d/go.mod h1:mL1N/T3taQHkDXs73rZJwtUhF3w3ftmwwsq0BUmARs4= | ||
| golang.org/x/net v0.0.0-20190213061140-3a22650c66bd/go.mod h1:mL1N/T3taQHkDXs73rZJwtUhF3w3ftmwwsq0BUmARs4= | ||
| golang.org/x/net v0.0.0-20190311183353-d8887717615a/go.mod h1:t9HGtf8HONx5eT2rtn7q6eTqICYqUVnKs3thJo3Qplg= | ||
| golang.org/x/net v0.0.0-20190620200207-3b0461eec859/go.mod h1:z5CRVTTTmAJ677TzLLGU+0bjPO0LkuOLi4/5GtJWs/s= | ||
| golang.org/x/oauth2 v0.0.0-20180821212333-d2e6202438be/go.mod h1:N/0e6XlmueqKjAGxoOufVs8QHGRruUQn6yWY3a++T0U= | ||
| golang.org/x/sync v0.0.0-20180314180146-1d60e4601c6f/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM= | ||
| golang.org/x/sync v0.0.0-20181108010431-42b317875d0f/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM= | ||
| golang.org/x/sync v0.0.0-20190227155943-e225da77a7e6/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM= | ||
| golang.org/x/sys v0.0.0-20180830151530-49385e6e1522/go.mod h1:STP8DvDyc/dI5b8T5hshtkjS+E42TnysNCUPdjciGhY= | ||
| golang.org/x/sys v0.0.0-20190215142949-d0b11bdaac8a/go.mod h1:STP8DvDyc/dI5b8T5hshtkjS+E42TnysNCUPdjciGhY= | ||
| golang.org/x/sys v0.0.0-20190502145724-3ef323f4f1fd/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs= | ||
| golang.org/x/text v0.3.0/go.mod h1:NqM8EUOU14njkJ3fqMW+pc6Ldnwhi/IjpwHt7yyuwOQ= | ||
| golang.org/x/text v0.3.3/go.mod h1:5Zoc/QRtKVWzQhOtBMvqHzDpF6irO9z98xDceosuGiQ= | ||
| golang.org/x/tools v0.0.0-20180917221912-90fa682c2a6e/go.mod h1:n7NCudcB/nEzxVGmLbDWY5pfWTLqBcC2KZ6jyYvM4mQ= | ||
| golang.org/x/tools v0.0.0-20190114222345-bf090417da8b/go.mod h1:n7NCudcB/nEzxVGmLbDWY5pfWTLqBcC2KZ6jyYvM4mQ= | ||
| golang.org/x/tools v0.0.0-20190226205152-f727befe758c/go.mod h1:9Yl7xja0Znq3iFh3HoIrodX9oNMXvdceNzlUR8zjMvY= | ||
| golang.org/x/tools v0.0.0-20190311212946-11955173bddd/go.mod h1:LCzVGOaR6xXOjkQ3onu1FJEFr0SW1gC7cKk1uF8kGRs= | ||
| google.golang.org/appengine v1.1.0/go.mod h1:EbEs0AVv82hx2wNQdGPgUI5lhzA/G0D9YwlJXL52JkM= | ||
| google.golang.org/appengine v1.4.0/go.mod h1:xpcJRLb0r/rnEns0DIKYYv+WjYCduHsrkT7/EB5XEv4= | ||
| google.golang.org/genproto v0.0.0-20180817151627-c66870c02cf8/go.mod h1:JiN7NxoALGmiZfu7CAH4rXhgtRTLTxftemlI0sWmxmc= | ||
| google.golang.org/genproto v0.0.0-20190425155659-357c62f0e4bb/go.mod h1:VzzqZJRnGkLBvHegQrXjBqPurQTc5/KpmUdxsrq26oE= | ||
| google.golang.org/grpc v1.19.0/go.mod h1:mqu4LbDTu4XGKhr4mRzUsmM4RtVoemTSY81AxZiDr8c= | ||
| google.golang.org/grpc v1.20.1/go.mod h1:10oTOabMzJvdu6/UiuZezV6QK5dSlG84ov/aaiqXj38= | ||
| gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0= | ||
| gopkg.in/yaml.v2 v2.2.2/go.mod h1:hI93XBmqTisBFMUTm0b8Fm+jr3Dg1NNxqwp+5A1VGuI= | ||
| gopkg.in/yaml.v3 v3.0.0-20200313102051-9f266ea9e77c h1:dUUwHk2QECo/6vqA44rthZ8ie2QXMNeKRTHCNY2nXvo= | ||
| honnef.co/go/tools v0.0.0-20190102054323-c2f93a96b099/go.mod h1:rf3lG4BRIbNafJWhAfAdb/ePZxsR/4RtNHQocxwk9r4= |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,21 @@ | ||
| // Copyright The OpenTelemetry Authors | ||
| // | ||
| // 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. | ||
|
|
||
| package internal // import "go.opentelemetry.io/otel/bridge/opencensus/internal" | ||
|
|
||
| import "go.opentelemetry.io/otel" | ||
|
|
||
| // Handle is the package level function to handle errors. It can be | ||
| // overwritten for testing. | ||
| var Handle = otel.Handle |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,47 @@ | ||
| // Copyright The OpenTelemetry Authors | ||
| // | ||
| // 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. | ||
|
|
||
| package oc2otel // import "go.opentelemetry.io/otel/bridge/opencensus/internal/oc2otel" | ||
|
|
||
| import ( | ||
| octrace "go.opencensus.io/trace" | ||
|
|
||
| "go.opentelemetry.io/otel/attribute" | ||
| ) | ||
|
|
||
| func Attributes(attr []octrace.Attribute) []attribute.KeyValue { | ||
| otelAttr := make([]attribute.KeyValue, len(attr)) | ||
| for i, a := range attr { | ||
| otelAttr[i] = attribute.KeyValue{ | ||
| Key: attribute.Key(a.Key()), | ||
| Value: AttributeValue(a.Value()), | ||
| } | ||
| } | ||
| return otelAttr | ||
| } | ||
|
|
||
| func AttributeValue(ocval interface{}) attribute.Value { | ||
| switch v := ocval.(type) { | ||
| case bool: | ||
| return attribute.BoolValue(v) | ||
| case int64: | ||
| return attribute.Int64Value(v) | ||
| case float64: | ||
| return attribute.Float64Value(v) | ||
| case string: | ||
| return attribute.StringValue(v) | ||
| default: | ||
| return attribute.StringValue("unknown") | ||
| } | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,56 @@ | ||
| // Copyright The OpenTelemetry Authors | ||
| // | ||
| // 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. | ||
|
|
||
| package oc2otel | ||
|
|
||
| import ( | ||
| "testing" | ||
|
|
||
| octrace "go.opencensus.io/trace" | ||
|
|
||
| "go.opentelemetry.io/otel/attribute" | ||
| ) | ||
|
|
||
| func TestAttributes(t *testing.T) { | ||
| in := []octrace.Attribute{ | ||
| octrace.BoolAttribute("bool", true), | ||
| octrace.Int64Attribute("int64", 49), | ||
| octrace.Float64Attribute("float64", 1.618), | ||
| octrace.StringAttribute("key", "val"), | ||
| } | ||
|
|
||
| want := []attribute.KeyValue{ | ||
| attribute.Bool("bool", true), | ||
| attribute.Int64("int64", 49), | ||
| attribute.Float64("float64", 1.618), | ||
| attribute.String("key", "val"), | ||
| } | ||
| got := Attributes(in) | ||
|
|
||
| if len(got) != len(want) { | ||
| t.Errorf("Attributes conversion failed: want %#v, got %#v", want, got) | ||
| } | ||
| for i := range got { | ||
| if g, w := got[i], want[i]; g != w { | ||
| t.Errorf("Attributes conversion: want %#v, got %#v", w, g) | ||
| } | ||
| } | ||
| } | ||
|
|
||
| func TestAttributeValueUnknown(t *testing.T) { | ||
| got := AttributeValue([]byte{}) | ||
| if got != attribute.StringValue("unknown") { | ||
| t.Errorf("AttributeValue of unknown wrong: %#v", got) | ||
| } | ||
| } |
Oops, something went wrong.