Send span lines with span logs.

Author: keep94

senders/client.go

@@ -135,7 +135,7 @@ func (sender *wavefrontSender) SendSpan(name string, startMillis, durationMillis
 	}
 
 	if len(spanLogs) > 0 {
-		logs, err := SpanLogJSON(traceId, spanId, spanLogs)
+		logs, err := SpanLogJSON(traceId, spanId, spanLogs, line)
 		if err != nil {
 			sender.spanLogsInvalid.Inc()
 			return err

senders/direct.go

@@ -192,7 +192,7 @@ func (sender *directSender) SendSpan(name string, startMillis, durationMillis in
 	}
 
 	if len(spanLogs) > 0 {
-		logs, err := SpanLogJSON(traceId, spanId, spanLogs)
+		logs, err := SpanLogJSON(traceId, spanId, spanLogs, line)
 		if err != nil {
 			sender.spanLogsInvalid.Inc()
 			return err

senders/formatter.go

@@ -195,11 +195,12 @@ func SpanLine(name string, startMillis, durationMillis int64, source, traceId, s
 }
 
 // SpanLogJSON is for internal use only.
-func SpanLogJSON(traceId, spanId string, spanLogs []SpanLog) (string, error) {
+func SpanLogJSON(traceId, spanId string, spanLogs []SpanLog, span string) (string, error) {
 	l := SpanLogs{
 		TraceId: traceId,
 		SpanId:  spanId,
 		Logs:    spanLogs,
+		Span:    span,
 	}
 	out, err := json.Marshal(l)
 	if err != nil {

senders/proxy.go

@@ -255,7 +255,7 @@ func (sender *proxySender) SendSpan(name string, startMillis, durationMillis int
 	}
 
 	if len(spanLogs) > 0 {
-		logs, err := SpanLogJSON(traceId, spanId, spanLogs)
+		logs, err := SpanLogJSON(traceId, spanId, spanLogs, line)
 		if err != nil {
 			sender.spanLogsInvalid.Inc()
 			return err

senders/types.go

@@ -20,6 +20,7 @@ type SpanLogs struct {
 	TraceId string    `json:"traceId"`
 	SpanId  string    `json:"spanId"`
 	Logs    []SpanLog `json:"logs"`
+	Span    string    `json:"span"`
 }
 
 // MetricSender Interface for sending metrics to Wavefront