go/opentelemetry-go
go/opentelemetry-go
1
0
Fork 0
mirror of https://github.com/open-telemetry/opentelemetry-go.git synced 2025-02-01 13:07:51 +02:00
Code Issues Releases Activity

Fix "add event" event handling (#97)

Browse Source
This commit is contained in:
Krzesimir Nowak 2019-08-16 20:07:23 +02:00 committed by Ted Young
parent 56e1a9d1f4
commit 6dab220fc5
2 changed files with 4 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
experimental/streaming/exporter/reader/format/format.go
View File

@ -73,11 +73,12 @@ func AppendEvent(buf *strings.Builder, data reader.Event) {
case reader.ADD_EVENT:
buf.WriteString("event: ")
buf.WriteString(data.Event.Message())
buf.WriteString(data.Message)
buf.WriteString(" (")
for _, kv := range data.Event.Attributes() {
data.Attributes.Foreach(func(kv core.KeyValue) bool {
buf.WriteString(" " + kv.Key.Variable.Name + "=" + kv.Value.Emit())
}
return true
})
buf.WriteString(")")
case reader.MODIFY_ATTR:

2
experimental/streaming/exporter/reader/reader.go
View File

@ -22,7 +22,6 @@ import (
"google.golang.org/grpc/codes"
"go.opentelemetry.io/api/core"
"go.opentelemetry.io/api/event"
"go.opentelemetry.io/api/stats"
"go.opentelemetry.io/api/tag"
"go.opentelemetry.io/experimental/streaming/exporter/observer"
@ -41,7 +40,6 @@ type Event struct {
SpanContext core.SpanContext
Tags tag.Map
Attributes tag.Map
Event event.Event
Stats []Measurement
Parent core.SpanContext