tiennm99/keepalive
1
0 Fork 0
mirror of https://github.com/tiennm99/keepalive.git synced 2026-10-15 06:16:16 +00:00
Code Issues Packages Projects Releases Wiki Activity

Revert "refactor: use sample code from Aiven"

Browse Source 
This reverts commit 7bbc70bcbf6570c448c0d8a641b1dfa1f4b32ed3.
This commit is contained in:
tiennm99 committed 2025-11-27 00:11:30 +07:00
1 parent 3baf0e545c
commit 24c0f55480
2 files changed
+10 -5
Download Patch File Download Diff File Expand all files Collapse all files

No files matched your search

valkey/.env.example
+1 -1
View File
@@ -1 +1 @@
VALKEY_URI=valkey://default@127.0.0.1:6379
VALKEY_URL=valkey://default@127.0.0.1:6379
valkey/main.go
+9 -4
View File
@@ -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())