clandestined_rendezvous_hash_cluster_node_assignment.py

1from clandestined import Cluster
2
3# Define your nodes (e.g., server names or IPs)
4nodes = ['node1', 'node2', 'node3', 'node4']
5
6# Initialize the Cluster with the nodes
7# You can also provide a custom seed for the MurmurHash3 algorithm
8c = Cluster(nodes)
9
10# Find out which node is responsible for a given key
11key = 'my_data_key'
12responsible_node = c.find_node(key)
13
14print(f"The key '{key}' is assigned to: {responsible_node}")
15
16# You can also get a sorted list of nodes for a key (useful for replication)
17node_priority_list = c.get_nodes(key)
18print(f"Node priority for '{key}': {node_priority_list}")
19
20# Adding or removing nodes is easy
21c.add_node('node5')
22c.remove_node('node1')
23
24new_responsible_node = c.find_node(key)
25print(f"After cluster changes, '{key}' is assigned to: {new_responsible_node}")