Rename new registry

Author: cschleiden

internal/activity/executor_test.go

@@ -107,7 +107,7 @@ func TestExecutor_ExecuteActivity(t *testing.T) {
 	}
 	for _, tt := range tests {
 		t.Run(tt.name, func(t *testing.T) {
-			r := registry.NewRegistry()
+			r := registry.New()
 			attr := tt.setup(t, r)
 
 			e := &Executor{

internal/registry/registry.go

@@ -18,7 +18,7 @@ type Registry struct {
 	activityMap map[string]interface{}
 }
 
-func NewRegistry() *Registry {
+func New() *Registry {
 	return &Registry{
 		workflowMap: make(map[string]wf.Workflow),
 		activityMap: make(map[string]interface{}),

internal/registry/registry_test.go

@@ -83,7 +83,7 @@ func TestRegistry_RegisterWorkflow(t *testing.T) {
 	}
 	for _, tt := range tests {
 		t.Run(tt.name, func(t *testing.T) {
-			r := NewRegistry()
+			r := New()
 
 			err := r.RegisterWorkflow(tt.args.workflow, WithName(tt.args.name))
 
@@ -102,7 +102,7 @@ func TestRegistry_RegisterWorkflow(t *testing.T) {
 }
 
 func Test_RegisterWorkflow_Conflict(t *testing.T) {
-	r := NewRegistry()
+	r := New()
 	require.NotNil(t, r)
 
 	var wantErr *ErrWorkflowAlreadyRegistered
@@ -125,7 +125,7 @@ func reg_activity(ctx context.Context) error {
 }
 
 func Test_ActivityRegistration(t *testing.T) {
-	r := NewRegistry()
+	r := New()
 	require.NotNil(t, r)
 
 	err := r.RegisterActivity(reg_activity)
@@ -152,7 +152,7 @@ func reg_activity_invalid(ctx context.Context) {
 }
 
 func Test_ActivityRegistration_Invalid(t *testing.T) {
-	r := NewRegistry()
+	r := New()
 	require.NotNil(t, r)
 
 	err := r.RegisterActivity(reg_activity_invalid)
@@ -172,7 +172,7 @@ func (r *reg_activities) privateActivity(ctx context.Context) error {
 }
 
 func Test_ActivityRegistrationOnStruct(t *testing.T) {
-	r := NewRegistry()
+	r := New()
 	require.NotNil(t, r)
 
 	a := &reg_activities{
@@ -200,7 +200,7 @@ func Test_ActivityRegistrationOnStruct(t *testing.T) {
 }
 
 func Test_RegisterActivity_Conflict(t *testing.T) {
-	r := NewRegistry()
+	r := New()
 	require.NotNil(t, r)
 
 	var wantErr *ErrActivityAlreadyRegistered
@@ -226,7 +226,7 @@ func (r *reg_invalid_activities) Activity1(ctx context.Context) {
 }
 
 func Test_ActivityRegistrationOnStruct_Invalid(t *testing.T) {
-	r := NewRegistry()
+	r := New()
 	require.NotNil(t, r)
 
 	a := &reg_invalid_activities{

internal/workflow/cache/cache_test.go

@@ -24,7 +24,7 @@ import (
 func Test_Cache_StoreAndGet(t *testing.T) {
 	c := NewWorkflowExecutorLRUCache(metrics.NewNoopMetricsClient(), 1, time.Second*10)
 
-	r := registry.NewRegistry()
+	r := registry.New()
 	require.NoError(t, r.RegisterWorkflow(workflowWithActivity))
 
 	i := core.NewWorkflowInstance("instanceID", "executionID")
@@ -66,7 +66,7 @@ func Test_Cache_AutoEviction(t *testing.T) {
 	)
 
 	i := core.NewWorkflowInstance("instanceID", "executionID")
-	r := registry.NewRegistry()
+	r := registry.New()
 	require.NoError(t, r.RegisterWorkflow(workflowWithActivity))
 	e, err := wf.NewExecutor(
 		slog.Default(), trace.NewNoopTracerProvider().Tracer(backend.TracerName), r,
@@ -96,7 +96,7 @@ func Test_Cache_Evict(t *testing.T) {
 	)
 
 	i := core.NewWorkflowInstance("instanceID", "executionID")
-	r := registry.NewRegistry()
+	r := registry.New()
 	require.NoError(t, r.RegisterWorkflow(workflowWithActivity))
 	e, err := wf.NewExecutor(
 		slog.Default(), trace.NewNoopTracerProvider().Tracer(backend.TracerName), r,

internal/workflow/executor_test.go

@@ -584,7 +584,7 @@ func Test_Executor(t *testing.T) {
 
 	for _, tt := range tests {
 		t.Run(tt.name, func(t *testing.T) {
-			r := registry.NewRegistry()
+			r := registry.New()
 
 			i := core.NewWorkflowInstance(uuid.NewString(), "")
 			hp := &testHistoryProvider{}

tester/tester.go

@@ -174,7 +174,7 @@ func NewWorkflowTester[TResult any](workflow workflow.Workflow, opts ...Workflow
 	c.Set(time.Now())
 
 	wfi := core.NewWorkflowInstance(uuid.NewString(), uuid.NewString())
-	registry := registry.NewRegistry()
+	registry := registry.New()
 
 	options := &options{
 		TestTimeout: time.Second * 10,

worker/worker.go

@@ -41,7 +41,7 @@ func New(backend backend.Backend, options *Options) *Worker {
 		}
 	}
 
-	registry := registry.NewRegistry()
+	registry := registry.New()
 
 	// Register internal activities
 	if err := registry.RegisterActivity(&signals.Activities{Signaler: client.New(backend)}); err != nil {