From 25b40c0024065524d7790c12c62e72307bbd7fb1 Mon Sep 17 00:00:00 2001 From: Adar Ovadia Date: Sun, 29 Sep 2024 07:50:15 +0000 Subject: [PATCH] fix examples Signed-off-by: Adar Ovadia --- examples/node/cluster_example.ts | 16 ++++++++-------- examples/node/standalone_example.ts | 21 +++++++++++---------- examples/python/cluster_example.py | 12 ++++++------ 3 files changed, 25 insertions(+), 24 deletions(-) diff --git a/examples/node/cluster_example.ts b/examples/node/cluster_example.ts index 887fdd1700..b45fe53d49 100644 --- a/examples/node/cluster_example.ts +++ b/examples/node/cluster_example.ts @@ -51,7 +51,7 @@ async function appLogic(client: GlideClusterClient) { const pong = await client.ping(); Logger.log("info", "app", `PING response: ${pong}`); - // Send INFO REPLICATION with routing option to all nodes + // Send INFO REPLICATION to all nodes const infoReplResps = await client.info({ sections: [InfoOptions.Replication], }); @@ -90,14 +90,14 @@ async function execAppLogic() { "glide", `Authentication error encountered: ${error}`, ); - throw error; + } else { + Logger.log( + "warn", + "glide", + `Client has closed and needs to be re-created: ${error}`, + ); } - - Logger.log( - "warn", - "glide", - `Client has closed and needs to be re-created: ${error}`, - ); + throw error; case error instanceof TimeoutError: // A request timed out. You may choose to retry the execution based on your application's logic diff --git a/examples/node/standalone_example.ts b/examples/node/standalone_example.ts index 5f1025d3bf..0716cd8475 100644 --- a/examples/node/standalone_example.ts +++ b/examples/node/standalone_example.ts @@ -26,7 +26,7 @@ async function createClient(nodesList = [{ host: "localhost", port: 6379 }]) { port: node.port, })); - // Check `GlideClusterClientConfiguration` for additional options. + // Check `GlideClientConfiguration` for additional options. return await GlideClient.createClient({ addresses: addresses, // if the server uses TLS, you'll need to enable it. Otherwise the connection attempt will time out silently. @@ -36,8 +36,8 @@ async function createClient(nodesList = [{ host: "localhost", port: 6379 }]) { /** * Executes the main logic of the application, performing basic operations - * such as SET, GET, PING, and INFO REPLICATION using the provided GlideClusterClient. - * @param client An instance of GlideClusterClient. + * such as SET, GET, PING, and INFO REPLICATION using the provided GlideClient. + * @param client An instance of GlideClient. */ async function appLogic(client: GlideClient) { // Send SET and GET @@ -47,7 +47,7 @@ async function appLogic(client: GlideClient) { const getResponse = await client.get("foo"); Logger.log("info", "app", `Get response is: ${getResponse?.toString()}`); - // Send PING to all primaries (according to Redis's PING request_policy) + // Send PING to primary const pong = await client.ping(); Logger.log("info", "app", `PING response: ${pong}`); } @@ -74,13 +74,14 @@ async function execAppLogic() { "glide", `Authentication error encountered: ${error}`, ); - throw error; + } else { + Logger.log( + "warn", + "glide", + `Client has closed and needs to be re-created: ${error}`, + ); } - Logger.log( - "warn", - "glide", - `Client has closed and needs to be re-created: ${error}`, - ); + throw error; case error instanceof TimeoutError: // A request timed out. You may choose to retry the execution based on your application's logic diff --git a/examples/python/cluster_example.py b/examples/python/cluster_example.py index 79da83ae51..c3cefbd14f 100644 --- a/examples/python/cluster_example.py +++ b/examples/python/cluster_example.py @@ -92,12 +92,12 @@ async def exec_app_logic(): "glide", f"Authentication error encountered: {e}", ) - raise e - Logger.log( - LogLevel.WARN, - "glide", - f"Client has closed and needs to be re-created: {e}", - ) + else: + Logger.log( + LogLevel.WARN, + "glide", + f"Client has closed and needs to be re-created: {e}", + ) raise e except TimeoutError as e: # A request timed out. You may choose to retry the execution based on your application's logic