added get_replica_connections function

falkordb/falkordb.py

@@ -75,6 +75,7 @@
         dynamic_startup_nodes=True,
         url=None,
         address_remap=None,
+        decode_responses=True
     ):
 
         conn = redis.Redis(
@@ -92,7 +93,7 @@
             encoding_errors=encoding_errors,
             charset=charset,
             errors=errors,
-            decode_responses=True,
+            decode_responses=decode_responses,
             retry_on_timeout=retry_on_timeout,
             retry_on_error=retry_on_error,
             ssl=ssl,
@@ -125,6 +126,7 @@
             self.sentinel, self.service_name = Sentinel_Conn(conn, ssl)
             conn = self.sentinel.master_for(self.service_name, ssl=ssl)
 
+
         if Is_Cluster(conn):
             conn = Cluster_Conn(
                 conn,
@@ -225,6 +227,40 @@
 
         return self.connection.execute_command(CONFIG_CMD, "GET", name)[1]
 
+
+    def get_replica_connections(self):
+        """
+        Retrieve a list of connections for FalkorDB replicas.
+
+        This function determines the FalkorDB setup (Sentinel or Cluster) and returns 
+        the hostnames and ports of the replicas.
+
+        Returns:
+            list of tuple: A list of (hostname, port) tuples representing the 
+            replica connections.
+
+        Raises:
+            ConnectionError: If unable to connect or retrieve information from 
+            the FalkorDB setup.
+            ValueError: If the `mode` is neither Sentinel nor Cluster.
+        """
+        # decide if it's Sentinel or cluster
+        try:
+            mode = self.connection.execute_command("info")['redis_mode']
+        except Exception as e:
+            raise Exception(f"Failed to get Redis mode: {e}")
+
+        if hasattr(self, 'sentinel') and self.sentinel is not None:
+            replica_hostnames = self.sentinel.discover_slaves(service_name=self.service_name)
+            return [(host, int(port)) for host, port in replica_hostnames]
+        elif mode == "cluster":
+            data = self.connection.cluster_nodes()
+            return [(flag['hostname'], int(ip_port.split(':')[1])) for ip_port, flag in data.items() if 'slave' in flag["flags"] and flag["hostname"]]
+        else:
+            raise ValueError(f"Unsupported Redis mode: {mode}")
+
+
+
     def config_set(self, name: str, value=None) -> None:
         """
         Update a DB level configuration.