update span kind

Author: Vadman97

sdk/highlight-go/log/logrus.go

@@ -3,11 +3,12 @@ package hlog
 import (
 	"context"
 	"fmt"
+	"strings"
+
 	"github.com/highlight/highlight/sdk/highlight-go"
 	"github.com/sirupsen/logrus"
 	"go.opentelemetry.io/otel/codes"
 	"go.opentelemetry.io/otel/trace"
-	"strings"
 
 	"go.opentelemetry.io/otel/attribute"
 	semconv "go.opentelemetry.io/otel/semconv/v1.25.0"
@@ -59,7 +60,7 @@ func (hook *Hook) Fire(entry *logrus.Entry) error {
 		ctx = context.TODO()
 	}
 
-	span, _ := highlight.StartTraceWithTimestamp(ctx, highlight.LogrusSpanName, entry.Time, []trace.SpanStartOption{trace.WithSpanKind(trace.SpanKindClient)})
+	span, _ := highlight.StartTraceWithTimestamp(ctx, highlight.LogrusSpanName, entry.Time, []trace.SpanStartOption{trace.WithSpanKind(trace.SpanKindProducer)})
 	defer highlight.EndTrace(span)
 
 	msg := entry.Message

sdk/highlight-go/log/util.go

@@ -108,7 +108,7 @@ func submitVercelLog(ctx context.Context, tracer trace.Tracer, projectID int, se
 	t := time.UnixMilli(log.Timestamp)
 	span, _ := highlight.StartTraceWithTracer(
 		ctx, tracer, highlight.LogSpanName, t,
-		[]trace.SpanStartOption{trace.WithSpanKind(trace.SpanKindClient)},
+		[]trace.SpanStartOption{trace.WithSpanKind(trace.SpanKindProducer)},
 		attribute.String(highlight.ProjectIDAttribute, strconv.Itoa(projectID)),
 		semconv.ServiceNameKey.String(serviceName),
 	)
@@ -224,7 +224,7 @@ func SubmitHTTPLog(ctx context.Context, tracer trace.Tracer, projectID int, lg L
 
 	span, _ := highlight.StartTraceWithTracer(
 		ctx, tracer, highlight.LogSpanName, t,
-		[]trace.SpanStartOption{trace.WithSpanKind(trace.SpanKindClient)},
+		[]trace.SpanStartOption{trace.WithSpanKind(trace.SpanKindProducer)},
 		attribute.String(highlight.ProjectIDAttribute, strconv.Itoa(projectID)),
 	)
 	defer highlight.EndTrace(span)

sdk/highlight-go/otel.go

@@ -512,7 +512,7 @@ func RecordLog(ctx context.Context, record log.Record, tags ...log.KeyValue) err
 // Highlight session and trace are inferred from the context.
 // If no sessionID is set, then the error is associated with the project without a session context.
 func RecordError(ctx context.Context, err error, tags ...attribute.KeyValue) context.Context {
-	span, ctx := StartTraceWithTimestamp(ctx, ErrorSpanName, time.Now(), []trace.SpanStartOption{trace.WithSpanKind(trace.SpanKindClient)}, tags...)
+	span, ctx := StartTraceWithTimestamp(ctx, ErrorSpanName, time.Now(), []trace.SpanStartOption{trace.WithSpanKind(trace.SpanKindProducer)}, tags...)
 	defer EndTrace(span)
 	RecordSpanError(span, err)
 	return ctx