Move propagators

Author: cschleiden

backend/redis/signal.go

@@ -7,7 +7,7 @@ import (
 	"github.com/cschleiden/go-workflows/backend"
 	"github.com/cschleiden/go-workflows/backend/history"
 	"github.com/cschleiden/go-workflows/internal/log"
-	"github.com/cschleiden/go-workflows/internal/tracing"
+	"github.com/cschleiden/go-workflows/internal/propagators"
 	"github.com/cschleiden/go-workflows/workflow"
 	"github.com/redis/go-redis/v9"
 	"go.opentelemetry.io/otel/attribute"
@@ -30,7 +30,8 @@ func (rb *redisBackend) SignalWorkflow(ctx context.Context, instanceID string, e
 		return err
 	}
 
-	ctx, err = (&tracing.TracingContextPropagator{}).Extract(ctx, instanceState.Metadata)
+	// TODO: Can we do this in the client?
+	ctx, err = (&propagators.TracingContextPropagator{}).Extract(ctx, instanceState.Metadata)
 	if err != nil {
 		rb.Options().Logger.Error("extracting tracing context", log.ErrorKey, err)
 	}

backend/redis/workflow.go

@@ -11,7 +11,7 @@ import (
 	"github.com/cschleiden/go-workflows/backend/history"
 	"github.com/cschleiden/go-workflows/core"
 	"github.com/cschleiden/go-workflows/internal/log"
-	"github.com/cschleiden/go-workflows/internal/tracing"
+	"github.com/cschleiden/go-workflows/internal/propagators"
 	"github.com/cschleiden/go-workflows/internal/workflowerrors"
 	"github.com/cschleiden/go-workflows/workflow"
 	"github.com/redis/go-redis/v9"
@@ -301,7 +301,7 @@ func (rb *redisBackend) CompleteWorkflowTask(
 
 	if state == core.WorkflowInstanceStateFinished || state == core.WorkflowInstanceStateContinuedAsNew {
 		// Trace workflow completion
-		ctx, err = (&tracing.TracingContextPropagator{}).Extract(ctx, task.Metadata)
+		ctx, err = (&propagators.TracingContextPropagator{}).Extract(ctx, task.Metadata)
 		if err != nil {
 			rb.options.Logger.Error("extracting tracing context", log.ErrorKey, err)
 		}

internal/tracing/tracing.go renamed to internal/propagators/tracing.go

@@ -1,4 +1,4 @@
-package tracing
+package propagators
 
 import (
 	"context"