Consistent hash ring with virtual nodes shared by the Dragonfly scheduler, the Dragonfly client and the Dragonfly SDKs. Positions are SipHash-2-4 values with a zero key, so the Go module and the Rust crate place keys bit-for-bit identically and every component selects the same seed peer or scheduler for the same task.
| Package | Description |
|---|---|
| d7y.io/hashring | Go module for scheduler and SDK |
| dragonfly-hashring | Rust crate for client and SDK |
Go:
import "d7y.io/hashring"
ring := hashring.New()
ring.Add("default-seed-client-0")
ring.Add("default-seed-client-1")
vnode, _ := ring.Get(taskID)
name := vnode.Name()Rust:
use dragonfly_hashring::VNodeHashRing;
let mut ring = VNodeHashRing::new();
ring.add("default-seed-client-0".to_string());
ring.add("default-seed-client-1".to_string());
let name = ring.get(&task_id).unwrap().name();Both constructors use DefaultVNodesPerNode virtual nodes per node, pass hashring.WithVNodesPerNode(n) or call
VNodeHashRing::with_vnodes_per_node(n) to override it.
You can find the full documentation on the d7y.io.
Join the conversation and help the community grow. Here are the ways to get involved:
- Slack Channel: #dragonfly on CNCF Slack
- Github Discussions: Dragonfly Discussion Forum
- Developer Group: dragonfly-developers@googlegroups.com
- Mailing Lists:
- Developers: dragonfly-developers@googlegroups.com
- Maintainers: dragonfly-maintainers@googlegroups.com
- Twitter: @dragonfly_oss
You should check out our CONTRIBUTING and develop the project together.