@@ -89,16 +89,16 @@ func mockExportPipeline(t *testing.T) *push.Controller {
89
89
return controller
90
90
}
91
91
92
- type mockTraceProvider struct {
92
+ type mockTracerProvider struct {
93
93
tracer * mocktracer.Tracer
94
94
}
95
95
96
- func (p * mockTraceProvider ) Tracer (name string , options ... trace.TracerOption ) trace.Tracer {
96
+ func (p * mockTracerProvider ) Tracer (name string , options ... trace.TracerOption ) trace.Tracer {
97
97
return p .tracer
98
98
}
99
99
100
- func newTraceProvider () * mockTraceProvider {
101
- return & mockTraceProvider {
100
+ func newTracerProvider () * mockTracerProvider {
101
+ return & mockTracerProvider {
102
102
mocktracer .NewTracer (instrumentationName ),
103
103
}
104
104
}
@@ -122,14 +122,14 @@ func TestQuery(t *testing.T) {
122
122
controller := getController (t )
123
123
defer afterEach ()
124
124
cluster := getCluster ()
125
- traceProvider := newTraceProvider ()
125
+ tracerProvider := newTracerProvider ()
126
126
127
- ctx , parentSpan := traceProvider .tracer .Start (context .Background (), "gocql-test" )
127
+ ctx , parentSpan := tracerProvider .tracer .Start (context .Background (), "gocql-test" )
128
128
129
129
session , err := NewSessionWithTracing (
130
130
ctx ,
131
131
cluster ,
132
- WithTraceProvider ( traceProvider ),
132
+ WithTracerProvider ( tracerProvider ),
133
133
WithMeterProvider (controller .Provider ()),
134
134
WithConnectInstrumentation (false ),
135
135
)
@@ -147,7 +147,7 @@ func TestQuery(t *testing.T) {
147
147
parentSpan .End ()
148
148
149
149
// Get the spans and ensure that they are child spans to the local parent
150
- spans := traceProvider .tracer .EndedSpans ()
150
+ spans := tracerProvider .tracer .EndedSpans ()
151
151
152
152
// Collect all the connection spans
153
153
// total spans:
@@ -244,14 +244,14 @@ func TestBatch(t *testing.T) {
244
244
controller := getController (t )
245
245
defer afterEach ()
246
246
cluster := getCluster ()
247
- traceProvider := newTraceProvider ()
247
+ tracerProvider := newTracerProvider ()
248
248
249
- ctx , parentSpan := traceProvider .tracer .Start (context .Background (), "gocql-test" )
249
+ ctx , parentSpan := tracerProvider .tracer .Start (context .Background (), "gocql-test" )
250
250
251
251
session , err := NewSessionWithTracing (
252
252
ctx ,
253
253
cluster ,
254
- WithTraceProvider ( traceProvider ),
254
+ WithTracerProvider ( tracerProvider ),
255
255
WithMeterProvider (controller .Provider ()),
256
256
WithConnectInstrumentation (false ),
257
257
)
@@ -271,7 +271,7 @@ func TestBatch(t *testing.T) {
271
271
272
272
parentSpan .End ()
273
273
274
- spans := traceProvider .tracer .EndedSpans ()
274
+ spans := tracerProvider .tracer .EndedSpans ()
275
275
// total spans:
276
276
// 1 span for the query
277
277
// 1 span for the local span
@@ -342,22 +342,22 @@ func TestConnection(t *testing.T) {
342
342
controller := getController (t )
343
343
defer afterEach ()
344
344
cluster := getCluster ()
345
- traceProvider := newTraceProvider ()
345
+ tracerProvider := newTracerProvider ()
346
346
connectObserver := & mockConnectObserver {0 }
347
347
ctx := context .Background ()
348
348
349
349
session , err := NewSessionWithTracing (
350
350
ctx ,
351
351
cluster ,
352
- WithTraceProvider ( traceProvider ),
352
+ WithTracerProvider ( tracerProvider ),
353
353
WithMeterProvider (controller .Provider ()),
354
354
WithConnectObserver (connectObserver ),
355
355
)
356
356
require .NoError (t , err )
357
357
defer session .Close ()
358
358
require .NoError (t , session .AwaitSchemaAgreement (ctx ))
359
359
360
- spans := traceProvider .tracer .EndedSpans ()
360
+ spans := tracerProvider .tracer .EndedSpans ()
361
361
362
362
assert .Less (t , 0 , connectObserver .callCount )
363
363
0 commit comments