fixing bugs with cluster consistent hash routing (#14)

* fixing bugs with cluster consistent hash routing * fixed issues with K8s and sharding
petabridge · May 25, 2019 · c5bac6a · c5bac6a
1 parent 84baabc
commit c5bac6a
Show file tree

Hide file tree

Showing 6 changed files with 6 additions and 4 deletions.
diff --git a/k8s/tradeprocessor-deploy.yaml b/k8s/tradeprocessor-deploy.yaml
@@ -19,7 +19,7 @@ metadata:
     app: trade-processor
 spec:
   serviceName: trade-processor
-  replicas: 1
+  replicas: 3
   selector:
     matchLabels:
       app: trade-processor

diff --git a/src/Akka.CQRS.Pricing.Service/app.conf b/src/Akka.CQRS.Pricing.Service/app.conf
@@ -22,6 +22,7 @@ akka {
 
 		sharding{
 			role = "pricing-engine"
+			state-store-mode = ddata
 		}
 
 		client.receptionist.role = pricing-engine # stops ClusterClient gossip from going to the worker nodes

diff --git a/src/Akka.CQRS.TradePlacers.Service/Program.cs b/src/Akka.CQRS.TradePlacers.Service/Program.cs
@@ -32,7 +32,7 @@ static int Main(string[] args)
                 Props.Empty.WithRouter(new ClusterRouterGroup(
                     new ConsistentHashingGroup(new[] {"/user/orderbooks"},
                         TradeEventConsistentHashMapping.TradeEventMapping),
-                    ClusterRouterGroupSettings.FromConfig(conf))), "tradesRouter");
+                    new ClusterRouterGroupSettings(10000, new []{ "/user/orderbooks" }, true, useRole:"trade-processor"))), "tradesRouter");
 
             Cluster.Cluster.Get(actorSystem).RegisterOnMemberUp(() =>
             {

diff --git a/src/Akka.CQRS.TradePlacers.Service/app.conf b/src/Akka.CQRS.TradePlacers.Service/app.conf
@@ -3,7 +3,7 @@ akka {
 		provider = cluster
 
 		deployment{
-			/tradeRouter {
+			/tradesRouter {
 				router = consistent-hashing-group
 				routees.paths = ["/user/orderbooks"]
 				cluster {

diff --git a/src/Akka.CQRS.TradeProcessor.Service/app.conf b/src/Akka.CQRS.TradeProcessor.Service/app.conf
@@ -21,6 +21,7 @@
 
 		sharding{
 			role = "trade-processor"
+			state-store-mode = ddata
 		}
 	}
 

diff --git a/src/Akka.CQRS/Entities/Order.cs b/src/Akka.CQRS/Entities/Order.cs
@@ -14,7 +14,7 @@ namespace Akka.CQRS
     /// <summary>
     /// Represents an unfilled or partially unfilled trade inside the matching engine.
     /// </summary>
-    public struct Order : IWithOrderId, IWithStockId, IEquatable<Order>, IComparable<Order>, IComparable
+    public sealed class Order : IWithOrderId, IWithStockId, IEquatable<Order>, IComparable<Order>, IComparable
     {
         /// <summary>
         /// Represents an empty or completed trade.
-Original file line number
+Diff line change
@@ Expand Up / @@ -21,6 +21,7 @@ @@
     		sharding{
     			role = "trade-processor"
+    			state-store-mode = ddata
     		}
     	}
@@ Expand Down @@