diff --git a/pkg/net/trace/span.go b/pkg/net/trace/span.go index 635785f69..4715a301d 100644 --- a/pkg/net/trace/span.go +++ b/pkg/net/trace/span.go @@ -27,7 +27,11 @@ type Span struct { childs int } -func (s *Span) Name() string { +func (s *Span) ServiceName() string { + return s.operationName +} + +func (s *Span) OperationName() string { return s.operationName } diff --git a/pkg/net/trace/zipkin/zipkin.go b/pkg/net/trace/zipkin/zipkin.go index db6e1737f..aff0fa6c4 100644 --- a/pkg/net/trace/zipkin/zipkin.go +++ b/pkg/net/trace/zipkin/zipkin.go @@ -37,11 +37,12 @@ func (r *report) WriteSpan(raw *trace.Span) (err error) { ID: spanID, ParentID: &parentID, }, - Name: raw.Name(), + Name: raw.OperationName(), Timestamp: raw.StartTime(), Duration: raw.Duration(), Tags: make(map[string]string, len(tags)+len(logs)), } + span.LocalEndpoint = &model.Endpoint{ServiceName: raw.ServiceName()} for _, tag := range tags { switch tag.Key { case trace.TagSpanKind: @@ -55,8 +56,6 @@ func (r *report) WriteSpan(raw *trace.Span) (err error) { case "consumer": span.Kind = model.Consumer } - case trace.TagPeerService: - span.LocalEndpoint = &model.Endpoint{ServiceName: tag.Value.(string)} default: v, ok := tag.Value.(string) if ok {