feat(enhancement): add ForwardTo and RemoteForward (#538)

Tochemey · Nov 28, 2024 · 4fda560 · 4fda560
1 parent 92fe147
commit 4fda560
Show file tree

Hide file tree

Showing 17 changed files with 2,523 additions and 2,282 deletions.
diff --git a/actors/actor_system_test.go b/actors/actor_system_test.go
diff --git a/actors/api_test.go b/actors/api_test.go
@@ -64,7 +64,7 @@ func TestAsk(t *testing.T) {
 
 			// create a test actor
 			actorName := "test"
-			actor := newTestActor()
+			actor := newActor()
 			actorRef, err := sys.Spawn(ctx, actorName, actor)
 			require.NoError(t, err)
 			assert.NotNil(t, actorRef)
@@ -105,7 +105,7 @@ func TestAsk(t *testing.T) {
 
 			// create a test actor
 			actorName := "test"
-			actor := newTestActor()
+			actor := newActor()
 			actorRef, err := sys.Spawn(ctx, actorName, actor)
 			require.NoError(t, err)
 			assert.NotNil(t, actorRef)
@@ -149,7 +149,7 @@ func TestAsk(t *testing.T) {
 
 			// create a test actor
 			actorName := "test"
-			actor := newTestActor()
+			actor := newActor()
 			actorRef, err := sys.Spawn(ctx, actorName, actor)
 			require.NoError(t, err)
 			assert.NotNil(t, actorRef)
@@ -189,7 +189,7 @@ func TestAsk(t *testing.T) {
 
 			// create a test actor
 			actorName := "test"
-			actor := newTestActor()
+			actor := newActor()
 			actorRef, err := sys.Spawn(ctx, actorName, actor)
 			require.NoError(t, err)
 			assert.NotNil(t, actorRef)
@@ -232,7 +232,7 @@ func TestAsk(t *testing.T) {
 
 			// create a test actor
 			actorName := "test"
-			actor := newTestActor()
+			actor := newActor()
 			actorRef, err := sys.Spawn(ctx, actorName, actor)
 			require.NoError(t, err)
 			assert.NotNil(t, actorRef)
@@ -277,7 +277,7 @@ func TestAsk(t *testing.T) {
 
 			// create a test actor
 			actorName := "test"
-			actor := newTestActor()
+			actor := newActor()
 			actorRef, err := sys.Spawn(ctx, actorName, actor)
 			require.NoError(t, err)
 			assert.NotNil(t, actorRef)
@@ -320,7 +320,7 @@ func TestAsk(t *testing.T) {
 
 			// create a test actor
 			actorName := "test"
-			actor := newTestActor()
+			actor := newActor()
 			actorRef, err := sys.Spawn(ctx, actorName, actor)
 			require.NoError(t, err)
 			assert.NotNil(t, actorRef)
@@ -364,7 +364,7 @@ func TestTell(t *testing.T) {
 
 			// create a test actor
 			actorName := "test"
-			actor := newTestActor()
+			actor := newActor()
 			actorRef, err := sys.Spawn(ctx, actorName, actor)
 			require.NoError(t, err)
 			assert.NotNil(t, actorRef)
@@ -408,7 +408,7 @@ func TestTell(t *testing.T) {
 
 			// create a test actor
 			actorName := "test"
-			actor := newTestActor()
+			actor := newActor()
 			actorRef, err := sys.Spawn(ctx, actorName, actor)
 			require.NoError(t, err)
 			assert.NotNil(t, actorRef)
@@ -451,7 +451,7 @@ func TestTell(t *testing.T) {
 
 			// create a test actor
 			actorName := "test"
-			actor := newTestActor()
+			actor := newActor()
 			actorRef, err := sys.Spawn(ctx, actorName, actor)
 			require.NoError(t, err)
 			assert.NotNil(t, actorRef)
@@ -490,7 +490,7 @@ func TestTell(t *testing.T) {
 
 			// create a test actor
 			actorName := "test"
-			actor := newTestActor()
+			actor := newActor()
 			actorRef, err := sys.Spawn(ctx, actorName, actor)
 			require.NoError(t, err)
 			assert.NotNil(t, actorRef)
@@ -533,7 +533,7 @@ func TestTell(t *testing.T) {
 
 			// create a test actor
 			actorName := "test"
-			actor := newTestActor()
+			actor := newActor()
 			actorRef, err := sys.Spawn(ctx, actorName, actor)
 			require.NoError(t, err)
 			assert.NotNil(t, actorRef)

diff --git a/actors/cluster_config_test.go b/actors/cluster_config_test.go
@@ -37,7 +37,7 @@ func TestClusterConfig(t *testing.T) {
 	t.Run("With happy path", func(t *testing.T) {
 		disco := new(testkit.Provider)
 		exchanger := new(exchanger)
-		tester := new(testActor)
+		tester := new(actorQA)
 		kinds := []Actor{tester, exchanger}
 		config := NewClusterConfig().
 			WithKinds(kinds...).
@@ -60,7 +60,7 @@ func TestClusterConfig(t *testing.T) {
 
 	t.Run("With invalid config setting", func(t *testing.T) {
 		config := NewClusterConfig().
-			WithKinds(new(exchanger), new(testActor)).
+			WithKinds(new(exchanger), new(actorQA)).
 			WithDiscoveryPort(3220).
 			WithPeersPort(3222).
 			WithMinimumPeersQuorum(1).