change RejectedSpans to int64 to fit proto

Author: JayiceZ

app/vtinsert/opentelemetry/grpc.go

@@ -40,7 +40,7 @@ func getProtobufData(r *http.Request) ([]byte, error) {
 }
 
 // https://github.com/grpc/grpc/blob/master/doc/PROTOCOL-HTTP2.md#message-encoding
-func writeExportTraceResponses(w http.ResponseWriter, rejectedSpans uint64, errorMessage string) {
+func writeExportTraceResponses(w http.ResponseWriter, rejectedSpans int64, errorMessage string) {
 	resp := pb.ExportTraceServiceResponse{
 		ExportTracePartialSuccess: pb.ExportTracePartialSuccess{
 			RejectedSpans: rejectedSpans,
@@ -51,13 +51,7 @@ func writeExportTraceResponses(w http.ResponseWriter, rejectedSpans uint64, erro
 	grpcRespData := make([]byte, 5+len(respData))
 	grpcRespData[0] = 0
 	binary.BigEndian.PutUint32(grpcRespData[1:5], uint32(len(respData)))
-	for i := 0; i < len(grpcRespData); i++ {
-		print(grpcRespData[i])
-	}
 	copy(grpcRespData[5:], respData)
-	for i := 0; i < len(grpcRespData); i++ {
-		print(grpcRespData[i])
-	}
 	w.Header().Set("Content-Type", "application/grpc+proto")
 	w.Header().Set("Trailer", "grpc-status, grpc-message")
 

app/vtinsert/opentelemetry/opentelemetry.go

@@ -232,7 +232,7 @@ func pushFieldsFromScopeSpans(ss *otelpb.ScopeSpans, commonFields []logstorage.F
 
 func pushFieldsFromSpan(span *otelpb.Span, scopeCommonFields []logstorage.Field, lmp insertutil.LogMessageProcessor) []logstorage.Field {
 	fields := scopeCommonFields
-
+	println(span.TraceID)
 	fields = append(fields,
 		logstorage.Field{Name: otelpb.TraceIDField, Value: span.TraceID},
 		logstorage.Field{Name: otelpb.SpanIDField, Value: span.SpanID},

lib/protoparser/opentelemetry/pb/traces.go

@@ -115,7 +115,7 @@ func (r *ExportTraceServiceResponse) marshalProtobuf(mm *easyproto.MessageMarsha
 // ExportTracePartialSuccess represent partial success description in grpc response
 // https://github.com/open-telemetry/opentelemetry-proto/blob/v1.8.0/opentelemetry/proto/collector/trace/v1/trace_service.proto#L62
 type ExportTracePartialSuccess struct {
-	RejectedSpans uint64
+	RejectedSpans int64
 	ErrorMessage  string
 }
 
@@ -124,7 +124,7 @@ func (ps *ExportTracePartialSuccess) marshalProtobuf(mm *easyproto.MessageMarsha
 	//	int64 rejected_spans = 1;
 	//	string error_message = 2;
 	//}
-	mm.AppendFixed64(1, ps.RejectedSpans)
+	mm.AppendInt64(1, ps.RejectedSpans)
 	mm.AppendString(2, ps.ErrorMessage)
 }