From 24c0f55480c37288974332e8cde3f2031e3707e0 Mon Sep 17 00:00:00 2001 From: tiennm99 Date: Thu, 27 Nov 2025 00:11:30 +0700 Subject: [PATCH] Revert "refactor: use sample code from Aiven" This reverts commit 7bbc70bcbf6570c448c0d8a641b1dfa1f4b32ed3. --- valkey/.env.example | 2 +- valkey/main.go | 13 +++++++++---- 2 files changed, 10 insertions(+), 5 deletions(-) diff --git a/valkey/.env.example b/valkey/.env.example index 5fc695f..e0ea526 100644 --- a/valkey/.env.example +++ b/valkey/.env.example @@ -1 +1 @@ -VALKEY_URI=valkey://default@127.0.0.1:6379 +VALKEY_URL=valkey://default@127.0.0.1:6379 diff --git a/valkey/main.go b/valkey/main.go index 09a2578..b266a0a 100644 --- a/valkey/main.go +++ b/valkey/main.go @@ -17,15 +17,20 @@ func main() { log.Println("Warning: .env file not found") } - valkeyURI, isExist := os.LookupEnv("VALKEY_URI") + valkeyUrl, isExist := os.LookupEnv("VALKEY_URL") if !isExist { - log.Fatal("Warning: VALKEY_URI not set!") + log.Fatal("Warning: VALKEY_URL not set!") return } - client, err := valkey.NewClient(valkey.ClientOption{InitAddress: []string{valkeyURI}}) + opt, err := valkey.ParseURL(valkeyUrl) if err != nil { - panic(err) + log.Fatal(err) + } + + client, err := valkey.NewClient(opt) + if err != nil { + log.Fatal(err) } ctx, cancel := context.WithCancel(context.Background())