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