@@ -170,7 +170,7 @@ func (p *PropagatingToDownstreamInstrumenter[REQUEST, RESPONSE]) StartAndEndWith
170
170
}
171
171
172
172
func (p * PropagatingToDownstreamInstrumenter [REQUEST , RESPONSE ]) Start (parentContext context.Context , request REQUEST , options ... trace.SpanStartOption ) context.Context {
173
- newCtx := p .base .Start (parentContext , request )
173
+ newCtx := p .base .Start (parentContext , request , options ... )
174
174
if p .carrierGetter != nil {
175
175
if p .prop != nil {
176
176
p .prop .Inject (newCtx , p .carrierGetter (request ))
@@ -183,7 +183,7 @@ func (p *PropagatingToDownstreamInstrumenter[REQUEST, RESPONSE]) Start(parentCon
183
183
}
184
184
185
185
func (p * PropagatingToDownstreamInstrumenter [REQUEST , RESPONSE ]) End (ctx context.Context , request REQUEST , response RESPONSE , err error , options ... trace.SpanEndOption ) {
186
- p .base .End (ctx , request , response , err )
186
+ p .base .End (ctx , request , response , err , options ... )
187
187
}
188
188
189
189
func (p * PropagatingFromUpstreamInstrumenter [REQUEST , RESPONSE ]) StartAndEnd (parentContext context.Context , request REQUEST , response RESPONSE , err error , startTime , endTime time.Time ) {
@@ -226,12 +226,12 @@ func (p *PropagatingFromUpstreamInstrumenter[REQUEST, RESPONSE]) Start(parentCon
226
226
} else {
227
227
extracted = otel .GetTextMapPropagator ().Extract (parentContext , p .carrierGetter (request ))
228
228
}
229
- return p .base .Start (extracted , request )
229
+ return p .base .Start (extracted , request , options ... )
230
230
} else {
231
231
return parentContext
232
232
}
233
233
}
234
234
235
235
func (p * PropagatingFromUpstreamInstrumenter [REQUEST , RESPONSE ]) End (ctx context.Context , request REQUEST , response RESPONSE , err error , options ... trace.SpanEndOption ) {
236
- p .base .End (ctx , request , response , err )
236
+ p .base .End (ctx , request , response , err , options ... )
237
237
}
0 commit comments