mirror of
https://github.com/open-telemetry/opentelemetry-go.git
synced 2024-12-14 10:13:10 +02:00
1e1cc901a5
* Add trace/embedded * Update trace impl to use trace/embedded * Add noop pkg to replace no-op impl in trace pkg * Use trace/embedded in global impl * Use trace/embedded in SDK impl * Update opencensus bridge * Update opentracing bridge * Add changes to changelog * Update trace/doc.go Co-authored-by: David Ashpole <dashpole@google.com> --------- Co-authored-by: David Ashpole <dashpole@google.com>
118 lines
4.1 KiB
Go
118 lines
4.1 KiB
Go
// 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 noop // import "go.opentelemetry.io/otel/trace/noop"
|
|
|
|
import (
|
|
"context"
|
|
"reflect"
|
|
"testing"
|
|
|
|
"github.com/stretchr/testify/assert"
|
|
|
|
"go.opentelemetry.io/otel/trace"
|
|
)
|
|
|
|
func TestImplementationNoPanics(t *testing.T) {
|
|
// Check that if type has an embedded interface and that interface has
|
|
// methods added to it than the No-Op implementation implements them.
|
|
t.Run("TracerProvider", assertAllExportedMethodNoPanic(
|
|
reflect.ValueOf(TracerProvider{}),
|
|
reflect.TypeOf((*trace.TracerProvider)(nil)).Elem(),
|
|
))
|
|
t.Run("Meter", assertAllExportedMethodNoPanic(
|
|
reflect.ValueOf(Tracer{}),
|
|
reflect.TypeOf((*trace.Tracer)(nil)).Elem(),
|
|
))
|
|
t.Run("Span", assertAllExportedMethodNoPanic(
|
|
reflect.ValueOf(Span{}),
|
|
reflect.TypeOf((*trace.Span)(nil)).Elem(),
|
|
))
|
|
}
|
|
|
|
func assertAllExportedMethodNoPanic(rVal reflect.Value, rType reflect.Type) func(*testing.T) {
|
|
return func(t *testing.T) {
|
|
for n := 0; n < rType.NumMethod(); n++ {
|
|
mType := rType.Method(n)
|
|
if !mType.IsExported() {
|
|
t.Logf("ignoring unexported %s", mType.Name)
|
|
continue
|
|
}
|
|
m := rVal.MethodByName(mType.Name)
|
|
if !m.IsValid() {
|
|
t.Errorf("unknown method for %s: %s", rVal.Type().Name(), mType.Name)
|
|
}
|
|
|
|
numIn := mType.Type.NumIn()
|
|
if mType.Type.IsVariadic() {
|
|
numIn--
|
|
}
|
|
args := make([]reflect.Value, numIn)
|
|
ctx := context.Background()
|
|
for i := range args {
|
|
aType := mType.Type.In(i)
|
|
if aType.Name() == "Context" {
|
|
// Do not panic on a nil context.
|
|
args[i] = reflect.ValueOf(ctx)
|
|
} else {
|
|
args[i] = reflect.New(aType).Elem()
|
|
}
|
|
}
|
|
|
|
assert.NotPanicsf(t, func() {
|
|
_ = m.Call(args)
|
|
}, "%s.%s", rVal.Type().Name(), mType.Name)
|
|
}
|
|
}
|
|
}
|
|
|
|
func TestNewTracerProvider(t *testing.T) {
|
|
tp := NewTracerProvider()
|
|
assert.Equal(t, tp, TracerProvider{})
|
|
tracer := tp.Tracer("")
|
|
assert.Equal(t, tracer, Tracer{})
|
|
}
|
|
|
|
func TestTracerStartPropagatesSpanContext(t *testing.T) {
|
|
tracer := NewTracerProvider().Tracer("")
|
|
spanCtx := trace.SpanContext{}
|
|
|
|
ctx := trace.ContextWithSpanContext(context.Background(), spanCtx)
|
|
ctx, span := tracer.Start(ctx, "test_span")
|
|
assert.Equal(t, spanCtx, trace.SpanContextFromContext(ctx), "empty span context not set in context")
|
|
assert.IsType(t, Span{}, span, "non-noop span returned")
|
|
assert.Equal(t, spanCtx, span.SpanContext(), "empty span context not returned from span")
|
|
assert.False(t, span.IsRecording(), "empty span context returned recording span")
|
|
|
|
spanCtx = spanCtx.WithTraceID(trace.TraceID([16]byte{1}))
|
|
spanCtx = spanCtx.WithSpanID(trace.SpanID([8]byte{1}))
|
|
ctx = trace.ContextWithSpanContext(context.Background(), spanCtx)
|
|
ctx, span = tracer.Start(ctx, "test_span")
|
|
assert.Equal(t, spanCtx, trace.SpanContextFromContext(ctx), "non-empty span context not set in context")
|
|
assert.Equal(t, spanCtx, span.SpanContext(), "non-empty span context not returned from span")
|
|
assert.False(t, span.IsRecording(), "non-empty span context returned recording span")
|
|
|
|
rSpan := recordingSpan{Span: Span{sc: spanCtx}}
|
|
ctx = trace.ContextWithSpan(context.Background(), rSpan)
|
|
ctx, span = tracer.Start(ctx, "test_span")
|
|
assert.Equal(t, spanCtx, trace.SpanContextFromContext(ctx), "recording span's span context not set in context")
|
|
assert.IsType(t, Span{}, span, "non-noop span returned")
|
|
assert.Equal(t, spanCtx, span.SpanContext(), "recording span's span context not returned from span")
|
|
assert.False(t, span.IsRecording(), "recording span returned")
|
|
}
|
|
|
|
type recordingSpan struct{ Span }
|
|
|
|
func (recordingSpan) IsRecording() bool { return true }
|