fixup logs
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
This commit is contained in:
parent
c94af432a0
commit
adc400d7d4
@ -126,25 +126,8 @@ func (os *otSpan) Finish(opts ...tracer.SpanOption) {
|
|||||||
if !ok {
|
if !ok {
|
||||||
continue
|
continue
|
||||||
}
|
}
|
||||||
v, ok := os.opts.Labels[idx+1].(string)
|
v := os.opts.Labels[idx+1]
|
||||||
if !ok {
|
|
||||||
v = fmt.Sprintf("%v", os.opts.Labels[idx+1])
|
|
||||||
}
|
|
||||||
switch k {
|
|
||||||
case "err":
|
|
||||||
os.status = tracer.SpanStatusError
|
|
||||||
os.statusMsg = v
|
|
||||||
case "error":
|
|
||||||
continue
|
|
||||||
case "X-Request-Id", "x-request-id":
|
|
||||||
os.span.SetTag("x-request-id", v)
|
|
||||||
case "rpc.call", "rpc.call_type", "rpc.flavor", "rpc.service", "rpc.method",
|
|
||||||
"sdk.database", "db.statement", "db.args", "db.query", "db.method",
|
|
||||||
"messaging.destination.name", "messaging.source.name", "messaging.operation":
|
|
||||||
os.span.SetTag(k, v)
|
os.span.SetTag(k, v)
|
||||||
default:
|
|
||||||
os.span.LogKV(k, v)
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
if os.status == tracer.SpanStatusError {
|
if os.status == tracer.SpanStatusError {
|
||||||
os.span.SetTag("error", true)
|
os.span.SetTag("error", true)
|
||||||
@ -179,7 +162,17 @@ func (os *otSpan) Kind() tracer.SpanKind {
|
|||||||
}
|
}
|
||||||
|
|
||||||
func (os *otSpan) AddLabels(labels ...interface{}) {
|
func (os *otSpan) AddLabels(labels ...interface{}) {
|
||||||
os.opts.Labels = append(os.opts.Labels, labels...)
|
if len(labels)%2 != 0 {
|
||||||
|
labels = labels[:len(labels)-1]
|
||||||
|
}
|
||||||
|
for idx := 0; idx < len(labels); idx += 2 {
|
||||||
|
k, kok := labels[idx].(string)
|
||||||
|
if !kok {
|
||||||
|
continue
|
||||||
|
}
|
||||||
|
v := labels[idx+1]
|
||||||
|
os.span.SetTag(k, v)
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
func NewTracer(opts ...tracer.Option) *otTracer {
|
func NewTracer(opts ...tracer.Option) *otTracer {
|
||||||
|
Loading…
Reference in New Issue
Block a user