Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 1 addition & 1 deletion go.mod
Original file line number Diff line number Diff line change
Expand Up @@ -49,6 +49,7 @@ require (
github.com/valyala/fasttemplate v1.2.2
go.etcd.io/bbolt v1.3.7
go.etcd.io/etcd/client/v3 v3.5.9
go.opentelemetry.io/otel/trace v1.26.0
go.uber.org/atomic v1.10.0
golang.org/x/crypto v0.24.0
golang.org/x/exp v0.0.0-20230811145659-89c5cff77bcb
Expand Down Expand Up @@ -142,7 +143,6 @@ require (
go.opentelemetry.io/contrib/instrumentation/net/http/otelhttp v0.49.0 // indirect
go.opentelemetry.io/otel v1.26.0 // indirect
go.opentelemetry.io/otel/metric v1.26.0 // indirect
go.opentelemetry.io/otel/trace v1.26.0 // indirect
go.uber.org/multierr v1.6.0 // indirect
go.uber.org/zap v1.17.0 // indirect
golang.org/x/mod v0.17.0 // indirect
Expand Down
19 changes: 17 additions & 2 deletions log/impl.log.go
Original file line number Diff line number Diff line change
Expand Up @@ -8,9 +8,16 @@ import (
"github.com/pubgo/funk/errors"
"github.com/pubgo/funk/stack"
"github.com/rs/zerolog"
"go.opentelemetry.io/otel/trace"
"google.golang.org/protobuf/encoding/prototext"
)

const (
traceIDKey = "trace_id"
spanIDKey = "span_id"
traceFlagsKey = "trace_flags"
)

var _ Logger = (*loggerImpl)(nil)

type loggerImpl struct {
Expand Down Expand Up @@ -142,7 +149,7 @@ func (l *loggerImpl) Err(err error, ctxL ...context.Context) *zerolog.Event {
return nil
}

var fn = func(e *zerolog.Event) {
fn := func(e *zerolog.Event) {
if id := errors.GetErrorId(err); id != "" {
e.Str("error_id", id)
}
Expand Down Expand Up @@ -212,7 +219,7 @@ func (l *loggerImpl) newEvent(ctx context.Context, e *zerolog.Event) *zerolog.Ev
e = e.CallerSkipFrame(l.callerSkip)
}

if l.fields != nil && len(l.fields) > 0 {
if len(l.fields) > 0 {
e = e.Fields(l.fields)
}

Expand All @@ -221,5 +228,13 @@ func (l *loggerImpl) newEvent(ctx context.Context, e *zerolog.Event) *zerolog.Ev
e = e.Ctx(ctx)
}

span := trace.SpanFromContext(e.GetCtx())
spanCtx := span.SpanContext()
if spanCtx.IsValid() {
e.Str(spanIDKey, spanCtx.SpanID().String())
e.Str(traceIDKey, spanCtx.TraceID().String())
e.Str(traceFlagsKey, spanCtx.TraceFlags().String())
}

return mergeEvent(e, getEventFromCtx(ctx), l.content)
}