Make registry a public package

Author: cschleiden

internal/activity/executor.go

@@ -13,8 +13,8 @@ import (
 	"github.com/cschleiden/go-workflows/backend/payload"
 	"github.com/cschleiden/go-workflows/internal/args"
 	"github.com/cschleiden/go-workflows/internal/log"
-	"github.com/cschleiden/go-workflows/internal/registry"
 	"github.com/cschleiden/go-workflows/internal/workflowerrors"
+	"github.com/cschleiden/go-workflows/registry"
 	wf "github.com/cschleiden/go-workflows/workflow"
 	"go.opentelemetry.io/otel/attribute"
 	"go.opentelemetry.io/otel/trace"

internal/activity/executor_test.go

@@ -14,8 +14,8 @@ import (
 	"github.com/cschleiden/go-workflows/core"
 	"github.com/cschleiden/go-workflows/internal/args"
 	"github.com/cschleiden/go-workflows/internal/fn"
-	"github.com/cschleiden/go-workflows/internal/registry"
 	"github.com/cschleiden/go-workflows/internal/workflowerrors"
+	"github.com/cschleiden/go-workflows/registry"
 	"github.com/google/uuid"
 	"github.com/stretchr/testify/require"
 	"go.opentelemetry.io/otel/trace"

internal/worker/activity.go

@@ -13,8 +13,8 @@ import (
 	"github.com/cschleiden/go-workflows/internal/activity"
 	"github.com/cschleiden/go-workflows/internal/metrickeys"
 	im "github.com/cschleiden/go-workflows/internal/metrics"
-	"github.com/cschleiden/go-workflows/internal/registry"
 	"github.com/cschleiden/go-workflows/internal/workflowerrors"
+	"github.com/cschleiden/go-workflows/registry"
 )
 
 func NewActivityWorker(

internal/worker/workflow.go

@@ -14,9 +14,9 @@ import (
 	"github.com/cschleiden/go-workflows/core"
 	"github.com/cschleiden/go-workflows/internal/metrickeys"
 	im "github.com/cschleiden/go-workflows/internal/metrics"
-	"github.com/cschleiden/go-workflows/internal/registry"
 	"github.com/cschleiden/go-workflows/internal/workflow"
 	"github.com/cschleiden/go-workflows/internal/workflow/cache"
+	"github.com/cschleiden/go-workflows/registry"
 )
 
 type WorkflowWorkerOptions struct {

internal/workflow/cache/cache_test.go

@@ -14,8 +14,8 @@ import (
 	"github.com/cschleiden/go-workflows/backend/metadata"
 	"github.com/cschleiden/go-workflows/core"
 	"github.com/cschleiden/go-workflows/internal/metrics"
-	"github.com/cschleiden/go-workflows/internal/registry"
 	wf "github.com/cschleiden/go-workflows/internal/workflow"
+	"github.com/cschleiden/go-workflows/registry"
 	"github.com/cschleiden/go-workflows/workflow"
 	"github.com/stretchr/testify/require"
 	"go.opentelemetry.io/otel/trace"

internal/workflow/executor.go

@@ -18,11 +18,11 @@ import (
 	"github.com/cschleiden/go-workflows/internal/contextvalue"
 	"github.com/cschleiden/go-workflows/internal/continueasnew"
 	"github.com/cschleiden/go-workflows/internal/log"
-	"github.com/cschleiden/go-workflows/internal/registry"
 	"github.com/cschleiden/go-workflows/internal/sync"
 	"github.com/cschleiden/go-workflows/internal/workflowerrors"
 	"github.com/cschleiden/go-workflows/internal/workflowstate"
 	"github.com/cschleiden/go-workflows/internal/workflowtracer"
+	"github.com/cschleiden/go-workflows/registry"
 	wf "github.com/cschleiden/go-workflows/workflow"
 	"go.opentelemetry.io/otel/trace"
 )

internal/workflow/executor_test.go

@@ -17,8 +17,8 @@ import (
 	"github.com/cschleiden/go-workflows/internal/args"
 	"github.com/cschleiden/go-workflows/internal/command"
 	"github.com/cschleiden/go-workflows/internal/fn"
-	"github.com/cschleiden/go-workflows/internal/registry"
 	"github.com/cschleiden/go-workflows/internal/sync"
+	"github.com/cschleiden/go-workflows/registry"
 	wf "github.com/cschleiden/go-workflows/workflow"
 	"github.com/google/uuid"
 	"github.com/stretchr/testify/require"

registry/errors.go

@@ -0,0 +1,33 @@
+package registry
+
+type ErrInvalidWorkflow struct {
+	msg string
+}
+
+func (e *ErrInvalidWorkflow) Error() string {
+	return e.msg
+}
+
+type ErrWorkflowAlreadyRegistered struct {
+	msg string
+}
+
+func (e *ErrWorkflowAlreadyRegistered) Error() string {
+	return e.msg
+}
+
+type ErrInvalidActivity struct {
+	msg string
+}
+
+func (e *ErrInvalidActivity) Error() string {
+	return e.msg
+}
+
+type ErrActivityAlreadyRegistered struct {
+	msg string
+}
+
+func (e *ErrActivityAlreadyRegistered) Error() string {
+	return e.msg
+}

internal/registry/registry.go renamed to registry/registry.go

@@ -25,38 +25,6 @@ func New() *Registry {
 	}
 }
 
-type ErrInvalidWorkflow struct {
-	msg string
-}
-
-func (e *ErrInvalidWorkflow) Error() string {
-	return e.msg
-}
-
-type ErrWorkflowAlreadyRegistered struct {
-	msg string
-}
-
-func (e *ErrWorkflowAlreadyRegistered) Error() string {
-	return e.msg
-}
-
-type ErrInvalidActivity struct {
-	msg string
-}
-
-func (e *ErrInvalidActivity) Error() string {
-	return e.msg
-}
-
-type ErrActivityAlreadyRegistered struct {
-	msg string
-}
-
-func (e *ErrActivityAlreadyRegistered) Error() string {
-	return e.msg
-}
-
 type RegisterConfig struct {
 	Name string
 }