Merge pull request #1048 from asynkron/fix-examples

Fix examples
asynkron · Apr 6, 2024 · b92b3b7 · b92b3b7
2 parents 98b5bb6 + 22c10dc
commit b92b3b7
Show file tree

Hide file tree

Showing 49 changed files with 1,530 additions and 60 deletions.
diff --git a/cluster/cluster.pb.go b/cluster/cluster.pb.go
diff --git a/cluster/cluster_test_tool/pubsub_cluster.pb.go b/cluster/cluster_test_tool/pubsub_cluster.pb.go
diff --git a/cluster/gossip.pb.go b/cluster/gossip.pb.go
diff --git a/cluster/grain.pb.go b/cluster/grain.pb.go
diff --git a/cluster/pubsub.pb.go b/cluster/pubsub.pb.go
diff --git a/cluster/pubsub_test.pb.go b/cluster/pubsub_test.pb.go
diff --git a/examples/cluster-basic/node1/main.go b/examples/cluster-basic/node1/main.go
@@ -1,8 +1,8 @@
 package main
 
 import (
+	"cluster-basic/shared"
 	"fmt"
-
 	console "github.com/asynkron/goconsole"
 	"github.com/asynkron/protoactor-go/actor"
 	"github.com/asynkron/protoactor-go/cluster"
@@ -18,7 +18,7 @@ func main() {
 	console.ReadLine()
 	pid := c.Get("abc", "hello")
 	fmt.Printf("Got pid %v", pid)
-	res, _ := c.Request("abc", "hello", &actor.Touch{})
+	res, _ := c.Request("abc", "hello", &shared.HelloRequest{Name: "Roger"})
 	fmt.Printf("Got response %v", res)
 
 	fmt.Println()

diff --git a/examples/cluster-basic/node2/main.go b/examples/cluster-basic/node2/main.go
@@ -33,8 +33,9 @@ func startNode() *cluster.Cluster {
 		switch msg := ctx.Message().(type) {
 		case *actor.Started:
 			fmt.Printf("Started %v", msg)
-		case *shared.Hello:
+		case *shared.HelloRequest:
 			fmt.Printf("Hello %v\n", msg.Name)
+			ctx.Respond(&shared.HelloResponse{})
 		}
 	})
 	helloKind := cluster.NewKind("hello", props)

diff --git a/examples/cluster-basic/shared/protos.pb.go b/examples/cluster-basic/shared/protos.pb.go
diff --git a/examples/cluster-basic/shared/protos.proto b/examples/cluster-basic/shared/protos.proto
@@ -2,6 +2,10 @@ syntax = "proto3";
 package shared;
 option go_package = "github.com/asynkron/protoactor-go/examples/cluster-basic/shared";
 
-message Hello {
+message HelloRequest {
   string name = 1;
 }
+
+message HelloResponse {
+
+}
diff --git a/examples/cluster-broadcast/shared/protos.pb.go b/examples/cluster-broadcast/shared/protos.pb.go
diff --git a/examples/cluster-broadcast/shared/protos_grain.pb.go b/examples/cluster-broadcast/shared/protos_grain.pb.go
diff --git a/examples/cluster-error-response/protos.pb.go b/examples/cluster-error-response/protos.pb.go
diff --git a/examples/cluster-error-response/protos_grain.pb.go b/examples/cluster-error-response/protos_grain.pb.go
diff --git a/examples/cluster-eventstream-broadcast/protos.pb.go b/examples/cluster-eventstream-broadcast/protos.pb.go
diff --git a/examples/cluster-gossip/docker-compose.yml b/examples/cluster-gossip/docker-compose.yml
@@ -0,0 +1,48 @@
+version: '3.7'
+services:
+
+  consul-agent-1: &consul-agent
+    image: hashicorp/consul:latest
+    networks:
+      - consul
+    command: "agent -retry-join consul-server-bootstrap -client 0.0.0.0"
+
+  consul-agent-2:
+    <<: *consul-agent
+
+  consul-agent-3:
+    <<: *consul-agent
+
+  consul-server-1: &consul-server
+    <<: *consul-agent
+    command: "agent -server -retry-join consul-server-bootstrap -client 0.0.0.0"
+
+  consul-server-2:
+    <<: *consul-server
+
+  consul-server-bootstrap:
+    <<: *consul-agent
+    ports:
+      - "8400:8400"
+      - "8500:8500"
+      - "8600:8600"
+      - "8600:8600/udp"
+    command: "agent -server -bootstrap-expect 3 -ui -client 0.0.0.0"
+
+  mongodb:
+    image: mongo:latest
+    ports:
+      - 127.0.0.1:27017:27017
+    volumes:
+      - mongodb_data:/data/db
+
+  redis:
+    image: redis:latest
+    ports:
+      - 127.0.0.1:6379:6379
+
+networks:
+  consul:
+
+volumes:
+  mongodb_data: