Compare commits
3 Commits
Author | SHA1 | Date | |
---|---|---|---|
54d9857bb9 | |||
1e9abb9905 | |||
6b9edf3593 |
@@ -76,6 +76,8 @@ func (t *otTracer) Start(ctx context.Context, name string, opts ...tracer.SpanOp
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
sp.AddLabels(options.Labels...)
|
||||||
|
|
||||||
return tracer.NewSpanContext(ctx, sp), sp
|
return tracer.NewSpanContext(ctx, sp), sp
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -118,23 +120,29 @@ func (os *otSpan) Tracer() tracer.Tracer {
|
|||||||
}
|
}
|
||||||
|
|
||||||
func (os *otSpan) Finish(opts ...tracer.SpanOption) {
|
func (os *otSpan) Finish(opts ...tracer.SpanOption) {
|
||||||
if len(os.opts.Labels)%2 != 0 {
|
options := os.opts
|
||||||
os.opts.Labels = os.opts.Labels[:len(os.opts.Labels)-1]
|
for _, o := range opts {
|
||||||
|
o(&options)
|
||||||
}
|
}
|
||||||
os.opts.Labels = tracer.UniqLabels(os.opts.Labels)
|
|
||||||
for idx := 0; idx < len(os.opts.Labels); idx += 2 {
|
l := len(options.Labels)
|
||||||
k, ok := os.opts.Labels[idx].(string)
|
for idx := 0; idx < len(options.Labels); idx++ {
|
||||||
if !ok {
|
switch lt := options.Labels[idx].(type) {
|
||||||
continue
|
case attribute.KeyValue:
|
||||||
|
os.span.SetTag(string(lt.Key), lt.Value.AsInterface())
|
||||||
|
case string:
|
||||||
|
if l < idx+1 {
|
||||||
|
os.span.SetTag(lt, options.Labels[idx+1])
|
||||||
|
idx++
|
||||||
|
}
|
||||||
}
|
}
|
||||||
v := os.opts.Labels[idx+1]
|
|
||||||
os.span.SetTag(k, v)
|
|
||||||
}
|
}
|
||||||
|
|
||||||
if os.status == tracer.SpanStatusError {
|
if os.status == tracer.SpanStatusError {
|
||||||
os.span.SetTag("error", true)
|
os.span.SetTag("error", true)
|
||||||
os.span.LogKV("error", os.statusMsg)
|
os.span.LogKV("error", os.statusMsg)
|
||||||
}
|
}
|
||||||
os.span.SetTag("span.kind", os.opts.Kind)
|
os.span.SetTag("span.kind", options.Kind)
|
||||||
os.span.Finish()
|
os.span.Finish()
|
||||||
}
|
}
|
||||||
|
|
||||||
|
Reference in New Issue
Block a user