clandestined_rendezvous_hashing_cluster_sharding_quickstart.py

1from clandestined import Cluster
2
3# Define your cluster nodes
4nodes = ['node1', 'node2', 'node3', 'node4']
5
6# Initialize the Cluster
7cluster = Cluster(nodes)
8
9# Add or remove nodes as needed
10cluster.add_node('node5')
11cluster.remove_node('node1')
12
13# Get the node for a specific key
14key = 'my_data_key'
15node = cluster.get_node(key)
16
17print(f"Key '{key}' is assigned to node: {node}")
18
19# Get an ordered list of nodes for a key (useful for replication/failover)
20nodes_priority = cluster.get_nodes(key)
21print(f"Priority list for key '{key}': {nodes_priority}")