Comments (3)
For implementation, see:
https://github.com/akka/akka/tree/master/akka-actor/src/main/scala/akka/routing
https://github.com/akka/akka/blob/master/akka-actor/src/main/scala/akka/routing/ConsistentHashing.scala
I guess the easiest way is to copy RoundRobinGroup and reimplement the *Logic class to deal with the 3 above listed ways of hashing.
But try to keep close to the Akka impl
from akka.net.
Some initial support added:
We now support consistent hashing through:
- Messages implementing ConsistentHashable
- Wrapping messages in a ConsistentHashableEnvelope message
via ConsistentHashGroup router.
from akka.net.
Added pool support also.
Can't mark this one as complete though, there are alot more magic to consistent hashing, Akka has virtual nodes and other features we need to deal with.
from akka.net.
Related Issues (20)
- Docs: comments on router supervision are out of date HOT 1
- Existing test cases started failing with timeout exception after upgrating from akka 1.4.31 to 1.5.13 HOT 4
- How to send message to Self from external callbacks? HOT 2
- Error while recovering snapshots for actors with particular format for PersistenceId HOT 1
- Akka Service Discovery heartbeat monitor is failing to find Azure Table resource HOT 1
- Is the page "Use-Case and Deployment Scenarios" still up to date? HOT 1
- Docs: old links to API Change documentation don't forward to the correct place
- Akka.Tests.Delivery.ReliableDeliveryRandomSpecs.ReliableDelivery_with_random_failures_must_work_with_flaky_network_without_resending failure HOT 1
- Akka.TestKit: `ImplicitSender` (`TestActor`) is lost inside `async` tests whenever synchronous methods are called
- [TestKit] SupervisorStrategy for TestActor is unused HOT 1
- Akka.TestKit: `Watch` and `Unwatch` are secretly asynchronous
- Akka.Cluster.Metrics mis-uses code-genned Protobuf objects for internal business logic HOT 1
- Sporadic failures of Watch/Ask with remote actors (e.g. Singleton)
- [Epic] Akka.NET .NET Aspire Support HOT 1
- Receiving message from Dead Letter actor instead of actual sender HOT 1
- ConsumerController is Deadlocked in WaitingForConfirmation Status HOT 2
- Update Sharding Custom Handoff Message documentation
- Akka.Streams: `DivertTo` requires `NotUsed` materialization value instead of being generic HOT 2
- Enable debug logging for ShardCoordinator/ShardRegion/Shard actors HOT 7
- Shard not receiving/handling EntityTerminated message after passivation HOT 7
Recommend Projects
-
React
A declarative, efficient, and flexible JavaScript library for building user interfaces.
-
Vue.js
🖖 Vue.js is a progressive, incrementally-adoptable JavaScript framework for building UI on the web.
-
Typescript
TypeScript is a superset of JavaScript that compiles to clean JavaScript output.
-
TensorFlow
An Open Source Machine Learning Framework for Everyone
-
Django
The Web framework for perfectionists with deadlines.
-
Laravel
A PHP framework for web artisans
-
D3
Bring data to life with SVG, Canvas and HTML. 📊📈🎉
-
Recommend Topics
-
javascript
JavaScript (JS) is a lightweight interpreted programming language with first-class functions.
-
web
Some thing interesting about web. New door for the world.
-
server
A server is a program made to process requests and deliver data to clients.
-
Machine learning
Machine learning is a way of modeling and interpreting data that allows a piece of software to respond intelligently.
-
Visualization
Some thing interesting about visualization, use data art
-
Game
Some thing interesting about game, make everyone happy.
Recommend Org
-
Facebook
We are working to build community through open source technology. NB: members must have two-factor auth.
-
Microsoft
Open source projects and samples from Microsoft.
-
Google
Google ❤️ Open Source for everyone.
-
Alibaba
Alibaba Open Source for everyone
-
D3
Data-Driven Documents codes.
-
Tencent
China tencent open source team.
from akka.net.