Skip to content

Commit 65b4e4d

Browse files
fix: Change WithTraceProvider to WithTracerProvider
1 parent ba357fb commit 65b4e4d

File tree

4 files changed

+22
-22
lines changed

4 files changed

+22
-22
lines changed

instrumentation/github.com/gocql/gocql/config.go

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -25,7 +25,7 @@ import (
2525
// TracedSessionConfig provides configuration for sessions
2626
// created with NewSessionWithTracing.
2727
type TracedSessionConfig struct {
28-
traceProvider trace.Provider
28+
tracerProvider trace.Provider
2929
meterProvider metric.Provider
3030
instrumentQuery bool
3131
instrumentBatch bool
@@ -80,11 +80,11 @@ func WithConnectObserver(observer gocql.ConnectObserver) TracedSessionOption {
8080
})
8181
}
8282

83-
// WithTraceProvider will set the trace provider used to get a tracer
83+
// WithTracerProvider will set the trace provider used to get a tracer
8484
// for creating spans. Defaults to global.TraceProvider()
85-
func WithTraceProvider(provider trace.Provider) TracedSessionOption {
85+
func WithTracerProvider(provider trace.Provider) TracedSessionOption {
8686
return TracedSessionOptionFunc(func(c *TracedSessionConfig) {
87-
c.traceProvider = provider
87+
c.tracerProvider = provider
8888
})
8989
}
9090

@@ -125,7 +125,7 @@ func WithConnectInstrumentation(enabled bool) TracedSessionOption {
125125

126126
func configure(options ...TracedSessionOption) *TracedSessionConfig {
127127
config := &TracedSessionConfig{
128-
traceProvider: global.TraceProvider(),
128+
tracerProvider: global.TraceProvider(),
129129
meterProvider: global.MeterProvider(),
130130
instrumentQuery: true,
131131
instrumentBatch: true,

instrumentation/github.com/gocql/gocql/gocql.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -29,7 +29,7 @@ import (
2929
func NewSessionWithTracing(ctx context.Context, cluster *gocql.ClusterConfig, options ...TracedSessionOption) (*gocql.Session, error) {
3030
config := configure(options...)
3131
instruments := newInstruments(config.meterProvider)
32-
tracer := config.traceProvider.Tracer(
32+
tracer := config.tracerProvider.Tracer(
3333
instrumentationName,
3434
trace.WithInstrumentationVersion(otelcontrib.SemVersion()),
3535
)

instrumentation/github.com/gocql/gocql/gocql_test.go

Lines changed: 15 additions & 15 deletions
Original file line numberDiff line numberDiff line change
@@ -89,16 +89,16 @@ func mockExportPipeline(t *testing.T) *push.Controller {
8989
return controller
9090
}
9191

92-
type mockTraceProvider struct {
92+
type mockTracerProvider struct {
9393
tracer *mocktracer.Tracer
9494
}
9595

96-
func (p *mockTraceProvider) Tracer(name string, options ...trace.TracerOption) trace.Tracer {
96+
func (p *mockTracerProvider) Tracer(name string, options ...trace.TracerOption) trace.Tracer {
9797
return p.tracer
9898
}
9999

100-
func newTraceProvider() *mockTraceProvider {
101-
return &mockTraceProvider{
100+
func newTracerProvider() *mockTracerProvider {
101+
return &mockTracerProvider{
102102
mocktracer.NewTracer(instrumentationName),
103103
}
104104
}
@@ -122,14 +122,14 @@ func TestQuery(t *testing.T) {
122122
controller := getController(t)
123123
defer afterEach()
124124
cluster := getCluster()
125-
traceProvider := newTraceProvider()
125+
tracerProvider := newTracerProvider()
126126

127-
ctx, parentSpan := traceProvider.tracer.Start(context.Background(), "gocql-test")
127+
ctx, parentSpan := tracerProvider.tracer.Start(context.Background(), "gocql-test")
128128

129129
session, err := NewSessionWithTracing(
130130
ctx,
131131
cluster,
132-
WithTraceProvider(traceProvider),
132+
WithTracerProvider(tracerProvider),
133133
WithMeterProvider(controller.Provider()),
134134
WithConnectInstrumentation(false),
135135
)
@@ -147,7 +147,7 @@ func TestQuery(t *testing.T) {
147147
parentSpan.End()
148148

149149
// Get the spans and ensure that they are child spans to the local parent
150-
spans := traceProvider.tracer.EndedSpans()
150+
spans := tracerProvider.tracer.EndedSpans()
151151

152152
// Collect all the connection spans
153153
// total spans:
@@ -244,14 +244,14 @@ func TestBatch(t *testing.T) {
244244
controller := getController(t)
245245
defer afterEach()
246246
cluster := getCluster()
247-
traceProvider := newTraceProvider()
247+
tracerProvider := newTracerProvider()
248248

249-
ctx, parentSpan := traceProvider.tracer.Start(context.Background(), "gocql-test")
249+
ctx, parentSpan := tracerProvider.tracer.Start(context.Background(), "gocql-test")
250250

251251
session, err := NewSessionWithTracing(
252252
ctx,
253253
cluster,
254-
WithTraceProvider(traceProvider),
254+
WithTracerProvider(tracerProvider),
255255
WithMeterProvider(controller.Provider()),
256256
WithConnectInstrumentation(false),
257257
)
@@ -271,7 +271,7 @@ func TestBatch(t *testing.T) {
271271

272272
parentSpan.End()
273273

274-
spans := traceProvider.tracer.EndedSpans()
274+
spans := tracerProvider.tracer.EndedSpans()
275275
// total spans:
276276
// 1 span for the query
277277
// 1 span for the local span
@@ -342,22 +342,22 @@ func TestConnection(t *testing.T) {
342342
controller := getController(t)
343343
defer afterEach()
344344
cluster := getCluster()
345-
traceProvider := newTraceProvider()
345+
tracerProvider := newTracerProvider()
346346
connectObserver := &mockConnectObserver{0}
347347
ctx := context.Background()
348348

349349
session, err := NewSessionWithTracing(
350350
ctx,
351351
cluster,
352-
WithTraceProvider(traceProvider),
352+
WithTracerProvider(tracerProvider),
353353
WithMeterProvider(controller.Provider()),
354354
WithConnectObserver(connectObserver),
355355
)
356356
require.NoError(t, err)
357357
defer session.Close()
358358
require.NoError(t, session.AwaitSchemaAgreement(ctx))
359359

360-
spans := traceProvider.tracer.EndedSpans()
360+
spans := tracerProvider.tracer.EndedSpans()
361361

362362
assert.Less(t, 0, connectObserver.callCount)
363363

instrumentation/github.com/gocql/gocql/instrument.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -40,7 +40,7 @@ type instruments struct {
4040
latency metric.Int64ValueRecorder
4141
}
4242

43-
// newInstruments will recreate instruments using a meter
43+
// newInstruments will create instruments using a meter
4444
// from the given provider p.
4545
func newInstruments(p metric.Provider) *instruments {
4646
meter := p.Meter(

0 commit comments

Comments
 (0)